我可以创建一个Kafka消费者来阅读Kafka中固定数量的消息吗?我的情况是无论如何不应该超过100,低于100就可以了。
8yparm6h1#
你可以设置 max.poll.records 到100。它表示在对poll()的单个调用中返回的最大记录数。您可以在此处找到更多消费者配置:https://kafka.apache.org/documentation.html#newconsumerconfigs
max.poll.records
1条答案
按热度按时间8yparm6h1#
你可以设置
max.poll.records
到100。它表示在对poll()的单个调用中返回的最大记录数。您可以在此处找到更多消费者配置:https://kafka.apache.org/documentation.html#newconsumerconfigs