kafka 常用参数

listeners=PLAINTEXT://192.168.40.8:9092

kafka 实际监听的地址

advertised.listeners=PLAINTEXT://192.168.40.8:9092

kafka 注册到 zk 中地址。客户端连接到 kafka 集群的任一 broker,该 broker 会返回 zk 中的 broker 信息。

min.insync.replicas=1

至少需要等 1 个副本确认后,producer 发送消息才算成功

auto.offset.reset=latest, earliest

新建一个消费组,latest 表示从最新的位置开始消费,earliest 表示从最旧的位置开始。原理是重置位点。

如果消费组已经存在,必然有位点信息,则会使用现有位点信息。

enable.auto.commit = false

是否自动提交。如果客户端一直不提交,则没有位点信息,而 auto.offset.reset 设为 latest 的话,则一直拉最新的消息。

producer 参数

acks = -1, 0, 1

 https://hackernoon.com/apache-kafkas-distributed-system-firefighter-the-controller-broker-1afca1eae302

猜你喜欢

转载自www.cnblogs.com/allenwas3/p/10001560.html