kafka如何通过发送消息测试是否安装成功？

1、首先，创建有一个副本分区test主题。

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

2、然后，进入服务所在目录，发送消息到主题test，执行如下命令：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

3、最后，从主题上消费消息，执行如下命令：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning，接收到消息就说明服务部署成功了。你学会了吗？