./kafka-topics.sh --create --zookeeper 192.168.22.110:2181, 192.168.22.111:2181, 192.168.22.112:2181 --replication-factor 2 --partitions 2 --topic idoall_testTopic

./kafka-topics.sh --list --zookeeper localhost:2181

 ./kafka-server-start.sh -daemon ../config/server.properties


./kafka-console-producer.sh --broker-list 192.168.22.110:9092 --topic test


./kafka-console-consumer.sh --bootstrap-server 192.168.22.111:9092 --topic test --from-beginning
 

./kafka-console-producer.sh --broker-list 192.168.22.110:9092 --topic test

./kafka-console-consumer.sh --bootstrap-server 192.168.22.112:9092 --topic idoall_testTopic --from-beginning

kafka 集群标准配置

 

kafka 集群标准配置

 

 

kafka 集群标准配置

 

相关文章:

  • 2021-10-20
  • 2022-12-23
  • 2018-09-11
  • 2021-10-07
  • 2021-12-31
  • 2021-05-24
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2021-06-18
  • 2021-11-08
  • 2022-01-18
  • 2019-08-29
  • 2021-10-14
  • 2021-09-30
  • 2022-02-07
相关资源
相似解决方案