#指定连接 Kafka 集群所需的 broker 地址清单 bootstrap.servers=localhost:9092 #producer 用于压缩数据的压缩类型,压缩类型有none、gzip、snappy,默认是无压缩。 #压缩最好用于批量处理,批量处理消息越多,压缩性能越好。 #消息被压缩后发送到broker集群,broker集群是不会进行解压缩的,只会把消息发送到消费者集群,然后由消费者来解压缩。 compression.type=none #生产者生产的消息被发送到哪个block,需要一个分组策略。 #分区处理类,默认partitioner基于 key 的 hash 表。 #partitioner.class= # 在向 producer 发送 ack 之前,broker允许等待的最大时间,否则会发送错误到客户端。 #request.timeout.ms= # 控制 KafkaProducer.send() 和 KafkaProducer.partitionsFor() 将阻塞多长时间。 #max.block.ms= #当消息到达的速度比发送速度快,会出现生产者组将发送的消息组合成单个批量请求的现象,或者客户端希望减少请求数量, #设置此参数,生产者将等待一个延迟,以便和其他的消息组合成一个批次发出,减少发送的请求数。 #linger.ms= #请求的最大字节数。 #max.request.size= #生产者批处理消息的字节数,以减少请求次数,这将改善client与server之间的性能。 #batch.size= # 生产者可以用来缓存消息的缓冲区大小。 #buffer.memory=
在网上看到生产端有个 acks 参数,但这个配置文件没有,先在 Kafka 的官网手册了解了一下,留待后面深入了解。
原文:https://www.cnblogs.com/sunshineliulu/p/12013723.html