如何使用 kafka-python 制作批量消费者？

Question

我一直在寻找一段时间，但我找不到用kafka-python 创建batch consumer 的方法。我找到了Java 的指南，但这并不是我想要实现的目标。实际上，我的目标只是消耗固定数量的记录，比如说并处理它们（执行一些转换），然后将它们存储到数据库中。

Answer 1

这是一个消费者论点：

max_poll_records (int) – 一次返回的最大记录数 单次调用 poll()。默认值：500

我认为 kafka-python 可以使用最大数量的记录进行批量消费，可能不完全是你所说的固定数量。