如何在Kafka集群中查询消息是否被正确发送？
1 Kafka集群中查询消息
Kafka集群是一种分布式，可扩展的发布订阅消息系统，其可以支持企业应用程序的实时处理需求，以及微服务架构等现代架构的实时消息传递。在Kafka集群中，查看消息是否被正确发送是很有必要的一个步骤，以确保系统的正常运行，那么如何查询消息是否被正确发送呢？
2 如何在Kafka集群中查询消息
2.1 使用Kafka命令行工具
Kafka中内置了一系列命令行工具，可以用来查询消息。首先，要运行Kafka相关的管理程序，如果使用Operator（早期版本），可以运行bin/Kafka-script.sh，如果使用Kafka Streams，可以使用bin / Kafka-run-class.sh开启，如果使用Kafka Connect，可以使用bin/ Kafka-server-start.sh开启，然后使用bin/Kafka-console- consume.sh – topic my-topic – from-beginning命令进行消息查询，如果想要查看消息的offset和消息的key/value，可以使用bin/Kafka-console-consumer.sh –topic my-topic –from-beginning – property print.key / property print.value参数。
实际例子：
在生产环境中，我们可以使用Kafka命令行工具来查询消息。
首先，要运行Kafka相关的管理程序，如果使用Operator（早期版本），可以运行bin/Kafka-script.sh，如果使用Kafka Streams，可以使用bin / Kafka-run-class.sh开启，如果使用Kafka Connect，可以使用bin/ Kafka-server-start.sh开启，然后使用bin/Kafka-console-consume.sh – topic my-topic – from-beginning命令进行消息查询，如果想要查看消息的offset和消息的key/value，可以使用bin/Kafka-console-consumer.sh –topic my-topic –from-beginning –property print.key /property print.value参数。
例如，在Kafka集群中，我们可以使用以下命令来查询my-topic主题的消息：
bin/Kafka-console-consumer.sh –topic my-topic –from-beginning –property print.key –property print.value
运行该命令后，将会查询my-topic主题的消息，并显示消息的offset和key/value。
2.2 使用Kafka内置脚本
Kafka自带有一些内置脚本，可以用于查看消息是否正常发送。当使用Kafka连接器时，可以使用bin/Kafka-consumer-groups.sh脚本查询消费者组信息，即查看主题的消息发送状态。此外，还可以使用bin/Kafka-topics.sh脚本查询主题消息的发送情况，此外，也可以使用bin/Kafka-configs.sh脚本查看特定主题的配置情况，以确保消息的正确发送。
在生产环境中查询Kafka消息，可以使用Kafka内置脚本，如Kafka-consumer-groups.sh，Kafka-topics.sh和Kafka-configs.sh。
1、使用Kafka-consumer-groups.sh脚本查询消费者组信息，即查看主题的消息发送状态：
首先，进入Kafka安装目录，执行以下命令：
bin/Kafka-consumer-groups.sh –bootstrap-server
其中，Kafka-broker-list是Kafka集群的broker地址，consumer-group-name是消费者组的名称。
执行完毕后，会返回消费者组的消息发送情况，如消费者组的成员列表，消费者组的偏移量，消费者组的消费主题等。
2、使用Kafka-topics.sh脚本查询主题消息的发送情况：
首先，进入Kafka安装目录，执行以下命令：
bin/Kafka-topics.sh –bootstrap-server
其中，Kafka-broker-list是Kafka集群的broker地址，topic-name是消息主题名称。
执行完毕后，会返回主题的消息发送情况，如主题的分区数，副本数，消息偏移量等。
2.3 使用外部工具
除了使用Kafka内置的命令行工具和脚本之外，还可以使用第三方工具，如：Kafka Manager，Lenses等，这些外部工具能够提供实时查看消息发送情况和挖掘实际运行状态的功能，还可以自动进行监控，发生异常时能够实时通知，对于查看消息是否正确发送有很好的帮助。
如果我是一位资深运维技术专家，我可以使用Kafka Manager来查询Kafka集群中的消息。Kafka Manager是一款开源的Kafka管理工具，可以帮助我们更有效地管理Kafka集群。
具体步骤如下：
安装Kafka Manager：首先，需要从GitHub上下载Kafka Manager的源码，然后通过sbt构建Kafka Manager，并将生成的可执行文件部署到服务器上。
配置Kafka Manager：接下来，需要在Kafka Manager的配置文件中添加Kafka集群的信息，如Zookeeper的地址、Kafka集群的地址、Kafka的版本等，这些信息都可以在Kafka集群的配置文件中获取到。
启动Kafka Manager：最后，只需要在服务器上启动Kafka Manager，就可以使用Kafka Manager来查询Kafka集群中的消息了。
以上就是使用Kafka Manager来查询Kafka集群中的消息的具体步骤，使用Kafka Manager可以轻松查看Kafka集群中的消息发送情况和挖掘实际运行状态，进而实现对Kafka集群的有效管理。
3 结语
以上就是Kafka集群中查询消息是否被正确发送的一些方法，每种方法都有自己的特点，可以根据具体的需求，选择一种最合适的方法，以确保消息的正确发送。