kafka的启动的应用

时间:2020-04-13 14:55:19   收藏:0   阅读:73

1.启动zookeeper

/opt/kafka/bin/zookeeper-server-start.sh  /opt/kafka/config/zookeeper.properties 

2.启动kafka

/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties 

3.创建主题 (让我们创建一个名为“test”的主题,它只包含一个分区,只有一个副本)

/opt/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 1704D
?
•           备注: 或者,您可以将代理配置为在发布不存在的主题时自动创建主题,而不是手动创建主题。

4.查看主题: 如果我们运行list topic命令,我们现在可以看到该主题

 

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

 

5.发送一些消息 Kafka附带一个命令行客户端,它将从文件或标准输入中获取输入,并将其作为消息发送到Kafka集群。默认情况下,每行将作为单独的消息发送。运行生产者,然后在控制台中键入一些消息以发送到服务器。

 

 /opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic 1704D
?
•       >等待输入发送的消息

6.启动消费者

/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.133:9092 --topic 1704D --from-beginning  从第一条开始接受
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.133:9092 --topic 1704D从现在生产者发送开始接受。





 

原文:https://www.cnblogs.com/shanzhongqi/p/12690915.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!