apache-kafka - 消耗 n 条记录中的 min 和 max n 条记录，但在等待 m 秒后返回记录

Question

我有一个用例，消费者必须消耗最少的 n 条记录才能开始下一次处理，但在等待 m 秒后，必须返回 p < n 的 p 条记录。有没有办法在kafka中实现这一点？我可以配置最小获取大小和最大轮询记录来控制记录数，但不确定如何实现问题的第二部分。

标签： apache-kafkakafka-consumer-apispring-kafka

Answer 1

没有fetch.min.records消费者财产。

如果您的记录大小相似，您可以使用fetch.min.bytes和来近似您的算法fetch.max.wait.ms。

max.poll.records除非 n 条记录已经可用，否则对您并没有真正的帮助。