关于kafka在Linux系统下使用CRT远程工具操作命令

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.创建主题(topic)

/opt/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.91.128:2181 --replication-factor 1 --partitions 1 --topic 1707D  

--bootstrap-server 指定zookeeper的地址端口    --replication-factor 备份    --partitions分区    --topic 主题

(备注: 或者,您可以将代理配置为在发布不存在的主题时自动创建主题,而不是手动创建主题。)

查看主题: /opt/kafka/bin/kafka-topics.sh --list --zookeeper 192.168.91.128:2181

删除主题:

(1)  在server.properties中增加设置,默认未开启    delete.topic.enable=true  

(2)   /opt/kafka/bin/kafka-topics.sh --delete --topic 1707D --zookeeper 192.168.91.128:2181 

4.再启动kafka的生成者(producer) ,发送消息

/opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.91.128:9092 --topic 1707D

5.最后启动kafka的消费者(consumer),接收消息

/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.91.128:9092 --topic 1707D --from-beginning  从第一条开始接收

/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.91.128:9092 --topic 1707D从现在生产者发送开始接收。

6.查看进程,杀死kafka进程

jps:查看zookeeper进程 (zookeeper是用java编写的)

ps:查看redis进程  (因为redis是用c语言编写的,所以不能直接查看

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容