[root@node01 kafka]# bin/kafka-topics.sh --create --bootstrap-server node01:9092 --replication-factor 2 --partitions 2 --topic mytest
Error while executing topic command : org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
[2020-02-03 16:08:58,131] ERROR java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
	at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
	at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
	at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
	at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
	at kafka.admin.TopicCommand$AdminClientTopicService.createTopic(TopicCommand.scala:242)
	at kafka.admin.TopicCommand$TopicService$class.createTopic(TopicCommand.scala:194)
	at kafka.admin.TopicCommand$AdminClientTopicService.createTopic(TopicCommand.scala:217)
	at kafka.admin.TopicCommand$.main(TopicCommand.scala:61)
	at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 2 larger than available brokers: 1.
 (kafka.admin.TopicCommand$)

这个错呢你可以看报错信息Replication factor: 2 larger than available brokers: 1.,他说Replication是1,但是你设置的是2大于了1
改一下就好了改成–replication 1

 bin/kafka-topics.sh --create --bootstrap-server node01:9092 --replication-factor 1 --partitions 2 --topic mytest

改完你可以去查看一下看看有没有创建成功

root@node01 kafka]#  bin/kafka-topics.sh --list --bootstrap-server node01:9092
__consumer_offsets
connect-test
javatest
mytest
test
Logo

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

更多推荐