kafka默认端口号9092,但是ZooKeeper默认端口号是2181
如图错误:
在这里插入图片描述
在这里插入图片描述
创建和更改主题分区时报错:
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING

查看配置文件server.properties中的ZK部分发现,ZK默认端口号指定是2181
在这里插入图片描述
然而我把kafka的默认端口号9092当成ZK的去用,所以报错,新手问题。。。
将端口号修改回来后,就OK了。
如下例子,将test主题分区号修改为5个:

llw@ubuntu:/opt/kafka_2.12-2.4.0$ sudo ./bin/kafka-topics.sh --alter  --zookeeper localhost:2181  --topic test  --partitions 5
WARNING: If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected
Adding partitions succeeded!

查看结果:
在这里插入图片描述

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐