kafka安装

标签：broker   serve   kafka安装   接收   启动   --   sum   stop   name   

Kafka操作。
（1）、启动kafka命令：
#cd?/opt/kafka_2.10-0.10.1.1/bin;
#?./kafka-server-start.sh /opt/kafka_2.10-0.10.1.1/config/server.properties &;
（2）、停止kafka命令：
#?./kafka-server-stop.sh
（3）、创建Topic：(创建一个名为test的topic，只有一个副本，一个分区。)
#./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic
test
（4）、列出所有Topic：
#./kafka-topics.sh -list -zookeeper 127.0.0.1:2181 ? ? ? ? ? ? ? ? ?
（5）、启动Producer并发送消息：
#./kafka-console-producer.sh --broker-list localhost:9092 --topic test
（输入相应的消息，eg:hello kafka;按Ctrl+C结束）
（6）、启动Consumer并接收消息：
#./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning

kafka安装

标签：broker   serve   kafka安装   接收   启动   --   sum   stop   name   

原文地址：https://blog.51cto.com/12390045/2361602