查询 Kafka 主题中指定键的最新消息的最新偏移量、分区和时间戳的方法

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《查询 Kafka 主题中指定键的最新消息的最新偏移量、分区和时间戳的方法》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

如何查询 kafka 并获取给定主题和消息密钥的最新消息的时间戳/偏移量/分区？

我们的应用程序采用 golang 和 java 语言。但是，任何解决方案都是受欢迎的。 提前致谢。

正确答案

消费者无法过滤或仅接收来自主题的某些消息。消费者将按顺序获取消息。

我们最多可以应用一些过滤器来确定特定的分区。但在该分区内，您必须出队才能获取坐标

如果您正在寻找特定的密钥，则必须使消息出队，然后在客户端应用过滤器。对于 ConsumerRecord，您可以获取偏移量、分区等。

标准方法是让消费者向表中写入消息的键和坐标，这也是您可能需要考虑的事情。

好了，本文到此结束，带大家了解了《查询 Kafka 主题中指定键的最新消息的最新偏移量、分区和时间戳的方法》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！