我安装了 Kafka 2.4.0,当我运行 kafka-topics.sh 命令时,我看到了奇怪的行为。
我可以毫无问题地启动zookeeper和kafka,当我运行这个时
kafka-topics.sh --bootstrap-server 127.0.0.1:2181 --version
我明白了:
2.4.0 (Commit:77a89fcf8d7fa018)
到目前为止,一切都很好。但如果我尝试列出所有主题:
kafka-topics.sh --bootstrap-server 127.0.0.1:2181 --list
命令挂起,我看到 Zookeeper 控制台重复显示此消息:
WARN Exception causing close of session 0x0: Unreasonable length = 308375649
起初我认为这可能与我也安装的 Confluence 5.3.2 发生冲突,但我删除了它。我卸载了Kafka,然后重新安装。没有喜悦。
H.Ç*_*Ç.T 19
kafka-topics.sh --bootstrap-server 127.0.0.1:2181 --list
问题是您正在使用zookeeper地址作为引导服务器地址。应该是这样的:
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list
Run Code Online (Sandbox Code Playgroud)
或者,您也可以将 Zookeeper 地址与 --zookeeper 参数一起使用,如下所示:
kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
Run Code Online (Sandbox Code Playgroud)
PS:在Kafka 2.2版本之前,zookeeper是topics.sh中唯一有效的选项,但之后bootstrap-server和zookeeper都是有效选项。您可以查看此内容以获取更多信息。
| 归档时间: |
|
| 查看次数: |
4049 次 |
| 最近记录: |