问题藐视：
我们使用ekuiper处理数据，然后把消息投送到kafka消息队列，后续发现消息丢失。
问题排查：
我们找到了程序代码，如下图所示。
我们在日志中搜索“kafka sink receive”数量，发现数量与数据生产者数量完全一致。
那么问题就可能出现在发送数据环节，调用kafka接口某些数据可能丢失，请帮忙定位问题。
我们在日志中搜索“kafka sink receive”数量，发现数量与数据生产者数量完全一致。
那么问题就可能出现在发送数据环节，调用kafka接口某些数据可能丢失，请帮忙定位问题。
如果是 kafka 发送数据失败的话，可以先查看日志搜索下 “kafka sink error” 关键字看下原因