kafka配置文件详解
程序员文章站
2024-03-15 13:27:53
...
#指定节点列表 metadata.broker.list=kafka01:9092,kafka02:9092,kafka03:9092 #指定分区处理类。默认kafka.producer.DefaultPartitioner #partitioner.class=kafka.producer.DefaultPartitioner #是否压缩,0代表不压缩,1代表用gzip压缩,2代表用snappy压缩 compression.codec=0 #指定序列化处理类 serializer.class=kafka.serializer.DefaultEncoder #如果要压缩消息,这里指定哪些topic要压缩消息,默认是empty,表示不压缩 #compressed.topics= #设置发送数据是否需要服务端的反馈,有三个值0,1,-1 # 0:producer不会等待broker发送ack # 1:当leader接收到消息后发送ack # -1:当所有的follower都同步消息成功后发送ack request.required.acks=0 #在向producer发送ack之前,broker均需等待的最大时间 request.timeout.ms=10000 #sync同步(默认),async异步可以提高发送吞吐量 producer.type=async #在async模式下,当message缓存超时后,将会批量发送给broker,默认5000ms #queue.buffering.max.ms=5000 #在async模式下,Producer端允许buffer的最大消息量 queue.buffering.max.messages=20000 #在async模式下,指定每次批量发送的数据量,默认200 batch.num.messages=500 #当消息在producer端沉积的条数达到“queue.buffering.max.messages"后 #阻塞一定时间后,队列仍然没有enqueue(producer仍然没有发送出任何消息) #此时producer可以继续阻塞,或者将消息抛弃 # -1:无阻塞超时限制,消息不会被抛弃 # 0 :立即清空队列,消息被抛弃 queue.enqueue.timeout.ms=-1
推荐阅读
-
kafka配置文件详解
-
Spring Aop demo 博客分类: Spring Spring Aop demoaop切面编程配置文件aop例子
-
kafka配置文件详解
-
PHP多维数组排序Array_multisort用法详解
-
TF内部公式详解
-
react没有嵌套关系的组件之间通信方法详解
-
Android Architecture Components介绍之ViewModel的使用详解
-
Vue之组件详解
-
Kafka的分布式架构设计与High Availability机制 博客分类: kafka kafka分布式busHAHigh Availability
-
Apache Geode 加载已有的配置文件到集群配置中 博客分类: 框架Apache Geode Apache Geode