因为好久没创建过kafka topic 经排查是zookeeper的地址有问题
因此地址需要一致:
kafka-topics.sh --create --topic test --zookeeper hadoop112:2181/kafka --partitions 5 --replication-factor 1
欢迎分享,转载请注明来源:内存溢出
因为好久没创建过kafka topic 经排查是zookeeper的地址有问题
因此地址需要一致:
kafka-topics.sh --create --topic test --zookeeper hadoop112:2181/kafka --partitions 5 --replication-factor 1
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)