在这里插入图片描述


1.问题描述
新启用了一个集群,正常启动kafka和zookeeper后,jps查看所有节点kafka和zookeeper都正常工作。
当使用命令行创建topic时

./kafka-topics.sh --zookeeper linux1:2181 --create --replication-factor 3 --partitions 1 --topic test-topic

,报了如下错误:

Error while executing topic command : Replication factor: 3 larger than available brokers: 0.
[2021-12-21 11:21:20,977] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 3 larger than available brokers: 0.
 (kafka.admin.TopicCommand$)

2.分析原因
大致意思是,将要创建的topic需要3个副本节点,但是当前可用节点为0.

好奇怪,我又检查了一遍kafka和zookeeper都正常启动,于是去看了下kafka的配置文件server.properties,发现了猫腻,原来指定了,kafka在zookeeper中的目录。

在这里插入图片描述
3.解决方案

分析出原因后就好办了,我们在命令行把指定的路径加进去就可以正常使用。

sudo ./kafka-topics.sh --zookeeper linux1:2181/kafka --create --replication-factor 3 --partitions 1 --topic test-topic

4.拓展:kafka tool
在连接kafka tool时也要配置指定路径,否则无法连接。
在这里插入图片描述

Logo

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

更多推荐