Kafka Consumer - 读取固定数量的消息

San*_*Das 2 apache-kafka kafka-consumer-api

我可以创建一个 kafka 消费者来读取 Kafka 中固定(比如 100)数量的消息吗?我的条件是无论如何不能超过100,低于100就可以了。

Nis*_*yal 5

可以设置max.poll.records为100。它表示单次调用poll()返回的最大记录数。

您可以在这里找到更多消费者配置: https ://kafka.apache.org/documentation.html#newconsumerconfigs