kafka集羣搭建

kafka集羣搭建

• zookeeper集羣搭建
• 從官網下載kafka，解壓
• 配置
  • config/server.properties

  host.name=master
  zookeeper.connect=master:2181,slave1:2181,slave2:2181

  • config/consumer.properties

  zookeeper.connect=master:2181,slave1:2181,slave2:2181

  • config/producer.properties

  metadata.broker.list=master:9092,slave1:9092,slave2:9092

• 啓動（3臺機器均啓動）

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

• 建立主題

./kafka-topics.sh --create --zookeeper master:2181 --replication-factor 1 --partitions 1 --topic test111

• 查看主題

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

• 建立發佈者

./kafka-console-producer.sh --broker-list master:9092 --topic test111

• 建立訂閱者

./kafka-console-consumer.sh --zookeeper master:2181 --topic test111 --from-beginning