错误信息:
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 3 larger than available brokers: 2.
根据错误信息,可知要创建的topic副本数为3,而brokers 为2 。表示kafka没有获取到zookeeper中的存储brokers信息。
检查:
kafka集群是否都正常启用,同时也要注意 创建的topic 副本数不能大于 集群中存活的broker数
lsof -i 查看各个kafka节点是否正常
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)