apache-kafka - 无法消费 Kafka 消息
问题描述
我已经设置了一个具有 1 个分区和 1 个复制因子的 Kafka 代理。我能够生成消息,但我不能使用它们。我没有收到任何错误,它看起来就像在等待某些东西。
我正在尝试使用以下命令来使用它们:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-kafka-topic --from-beginning
卡夫卡配置
broker.id=1
listeners = PLAINTEXT://:9092
log.dirs=/tmp/kafka_1-logs
Zookeeper 日志(最后一条消息)
[2019-11-04 22:49:28,859] INFO Accepted socket connection from /0:0:0:0:0:0:0:1:56069 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2019-11-04 22:49:28,860] INFO Client attempting to establish new session
at /0:0:0:0:0:0:0:1:56069 (org.apache.zookeeper.server.ZooKeeperServer)
[2019-11-04 22:49:28,990] INFO Established session 0x1000baf48760002 with
negotiated timeout 6000 for client /0:0:0:0:0:0:0:1:56069 (org.apache.zookeeper.server.ZooKeeperServer)
[2019-11-04 22:49:29,246] INFO Got user-level KeeperException when processing sessionid:0x1000baf48760002 type:multi cxid:0xc5 zxid:0x25e txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor)
制片人
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-kafka-topic
>hello
>howdy
>121
>
PS我正在关注本指南
更新
我正在预先创建主题。如果我不这样做并且我尝试发布一条消息,我会收到一条错误消息LEADER UNAVAILABLE
我检查了日志,从我尝试使用消息的那一刻起,服务器日志中没有任何内容。与此同时,终端无限期地等待。
控制器日志
> [2019-11-05 23:30:01,118] DEBUG [Controller id=1] Topics not in
> preferred replica for broker 0 Map()
> (kafka.controller.KafkaController) [2019-11-05 23:30:01,118] TRACE
> [Controller id=1] Leader imbalance ratio for broker 0 is 0.0
> (kafka.controller.KafkaController)
解决方案
推荐阅读
- reactjs - 如何在玩笑/酶测试中使用 React Hooks?
- java - 如何配置 Gradle 发布版本?
- ios - 在 LaunchScreen.storyboard 中设置不同的 LaunchImage
- laravel - 使用 Laravel 5.8 在后台保存外部 API 数据的最佳实践
- ansible - junos_l2_interface 删除描述,不是吗?
- javascript - 渲染对象 React 数组
- android-toolbar - 在 androidx.appcompat.app.ActionBarDrawerToggle 中不显示汉堡包按钮
- typescript - 具有接口类型之一的变量?
- qt - 由于 ssl 问题,无法在 Ubuntu 上安装 QT4
- reactjs - 动态组件在 React 中不起作用