-
0 votesanswersviews
如果ID = 0的代理已关闭,则Kafka群集不起作用
我有一个Kafka集群,其中包含3个代理配置如下: Broker-0 : broker.id=0 ; listeners=PLAINTEXT://localhost:9092 ; log.dirs=/opt/data/kafka/logs-0 Broker-1 : broker.id=1 ; listeners=PLAINTEXT://localhost:9093 ; log.dirs=/opt/... -
0 votesanswersviews
在连接器级别而不是工作者上覆盖/设置Kafka属性
我正在使用Kafka 0.10.0.1并希望在分布式模式下设置Kafka接收器 . 我在用户指南中注意到,消费者配置可以通过在前面添加“consumer”来覆盖,并且这些配置更改将应用于在该worker上运行的所有连接器 . 只是为了检查我的理解是否正确,我没有误解这一点 . 这意味着如果我想要使用不同的Kafka使用者属性运行多个连接器,例如auto.offset.reset,如果连接器在同一个... -
1 votesanswersviews
在zookeeper重启后,Kafka集群丢失消息
我正在使用Docker启动一个kafka经纪人集群(例如,5个经纪人,每个集装箱一个经纪人) . Kafka版本2.12-0.11.0.0,Zookeeper 3.4.10 . The scenario: 使用下面的配置启动第一个代理 zoo.cfg tickTime=2000 initLimit=10 syncLimit=5 dataDir=/opt/zookeeper/data cl...