我正在尝试开发一个应用程序，它从缓存中读取字节数组(表示 C 结构和与 UUID 关联的每个数组)，并通过 C 中的 Producer 应用程序将其发送到 Kafka 服务器。
kafka 生产者应用程序累积固定数量的此类数据包并立即发送它们。
我希望完成的是确认批处理中的哪些消息已成功传递，并取回它们的 UUID，以便我可以从缓存应用程序中清除它们。我是卡夫卡新手，请指导我完成这项工作的最佳方法是什么。
最佳答案
为什么不创建另一个消费者主题来“监听”已确认的消息，然后将它们从缓存中删除。然后生产者可以在需要时将消息推送到该主题。
关于c - 响应 Kafka Producer 发送的消息生成 UUID，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50718641/