哈喽,各位小伙伴,今天我来教大家,kafka如何通过发送消息测试是否安装成功?
工具/原料
ThinkPadEdgeE431
Widows10DirectX12
kafkav2.1.1
方法/步骤
1、首先,创建有一稍僚敉视个副本分区test主题。bin/kafka-topics.sh--create--zookeeperlocalhost:2181--replication-fa艘早祓胂ctor1--partitions1--topictest
2、然后,进入服务所在目录,发送消息到主题test,执行如下命令:bin/kafka-console-producer.sh--broker-listlocalhost:9092--topictest
3、最后,从主题上消费消息,执行如下命筠沭鱿漆令:bin/kafka-console-consumer.sh--bootstrap-serverlocalhost:9092--墉掠载牿topictest--from-beginning,接收到消息就说明服务部署成功了。你学会了吗?