问题描述:

在搭建kafka集群的时候,总共三个实例,broker.id分别为0、1、2,在创建副本数为3,分区数为2的新的topic时,出现错误如下:

排查错误的时候,使用jps命令,看到只是启动了两个kafka,因为id为0的那个一开始就是启动的,是通过它来配置其余的两个的,所以一直感觉可能是它出了问题,通过命令bin/kafka-server-start.sh -daemon config/server.properties启动之后,查看还是只有两个在运行中,因此通过zookeeper进行排查:

进入{zookeeper_home}/bin目录下

./zkCli.sh

然后

ls /brokers/ids

你会看到自己的节点数(是否是和你启动的是一样的)

果然,是由于id为2的实例没有启动,启动之后,问题解决!

如果还是有问题,那就重新启动kafka

Logo

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

更多推荐