有没有办法在1000条消息中只使用kafka队列中的第一条消息？我正在尝试用java实现同样的功能。我没有任何后端数据库。
6rqinv9w1#
现在你做不到，有kip-41可以解决这个问题。尽管您知道所需元素的大小，但在使用者中有一个名为fetch.message.max.bytes的属性，您可以将其设置为要轮询的元素的大小，并且每次轮询将只返回一条记录。
1条答案
按热度按时间6rqinv9w1#
现在你做不到，有kip-41可以解决这个问题。
尽管您知道所需元素的大小，但在使用者中有一个名为fetch.message.max.bytes的属性，您可以将其设置为要轮询的元素的大小，并且每次轮询将只返回一条记录。