# #,,卡夫卡启动
zookeeper-server 开始
bin/kafka-server-stop.sh
nohup bin/kafka-server-start.sh ,配置/server.properties ,祝辞,日志/kafka-server-start.log ,,
# #,查看当前节点状态
echo stat | nc 127.0.0.1 2181
#,创建主题,指定备份分区数
bin/kafka-topics.sh ——create ——zookeeper slave1.hadoop: 2181年,——replication-factor 2,
,,,,,,,,,,,,,,,,,,,,partitions 4——topic 测试题目
#查看主题
bin/kafka-topics.sh ——zookeeper slave1.hadoop: 2181——列表
bin/kafka-topics.sh ——zookeeper slave2.hadoop: 2181, - - -描述
bin/kafka-topics.sh ——zookeeper slave3.hadoop: 2181,——describe ——topic 测试题目
#创建生产商
bin/kafka-console-producer.sh ——broker-list slave3.hadoop: 9092,——topic test-topic ,,,,,,,
#创建consumer
bin/kafka-console-consumer.sh ——zookeeper standby.hadoop: 2181,——topic test-topic
bin/kafka-console-consumer.sh ——zookeeper standby.hadoop: 2181,——topic 测试题目
,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,from-beginning ,,
# #删除主题
bin/kafka-run-class.sh kafka.admin.TopicCommand ——zookeeper slave1.hadoop: 2181,
,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,topic 测试题目
,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,删除
bin/kafka-topics.sh ——zookeeper slave2.hadoop: 2181,,——delete ——topic 测试题目
