【问题标题】:How to listen to KAFKA topic which is configured chroot in broker in Java如何在 Java 中收听在代理中配置 chroot 的 KAFKA 主题
【发布时间】:2020-01-26 04:28:34
【问题描述】:

在Kafka broker中配置CHRoot,如何监听/chroot中的topic

【问题讨论】:

  • chroot 不能基于每个主题进行配置。使用时,它是代理的zookeeper.connect 属性的一部分。

标签: apache-kafka chroot


【解决方案1】:

自从 Kafka zookeeper.connect。

【讨论】:

  • 0.81 是一个古老的版本。新消费者应使用bootstrap.servers 配置连接到Kafka,请参阅kafka.apache.org/documentation/#consumerconfigs
  • @KarthiTamilveeran 请从该链接中删除 081,或使用您实际使用的 Kafka 版本的文档
  • 我同意,对于最新的 Kafka,不需要提供任何 chroot 路径,因为这仅适用于 zookeeper,而不是 KAFKA。
  • 当我连接到 KAFKA 2.11-0.11.0.2 [Consumer clientId=consumer-1, groupId=console-consumer-1784] 协调器发现失败,刷新元数据 (org.apache. kafka.clients.consumer.internals.AbstractCoordinator),然后在某个时间后超时
  • @Karthi 您可能想用您的代码和配置发布一个新问题,但您仍在使用旧版本的 Kafka。如果那是您的错误,我不确定我是否理解您为什么要询问 chroots
猜你喜欢
  • 2022-10-13
  • 2015-11-30
  • 1970-01-01
  • 1970-01-01
  • 2019-02-10
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多