2.1 初始化 2.1.1 程序入口 从用户自己编写的 main 方法开始阅读 package com.atguigu.kafka.producer; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.Prod
1、提高吞吐量 想要提高生产者的吞吐量可以通过调整一下4个参数来实现 batch.size：批次大小，默认16k linger.ms：等待时间，修改为5-100ms compression.type：压缩snappy RecordAccumulator：缓冲区大小，修改为64m 代码实现 public class CustomProducerParameters { public static v
kafka 一、基础架构 二、Kafka 快速入门 1、集群规划 2、集群部署 下载地址 1 ）解压安装包： tar -zxvf kafka_2.12-3.0.0.tgz -C /opt/module/ 2 ）修改解压后的文件名称: mv kafka_2.12-3.0.0/ kafka 3 ）进入到/opt/module/kafka 目录，修改配置文件 cd config/ vim server.p
