我想知道在处理Kafka Consumer中的Each方法之前，KStream(Kafka Streams)中的Poll返回了多少条记录。
我必须根据轮询返回的记录数量创建指标，并可以验证在forEach方法中处理了多少记录。
请问您对此有什么建议吗
uhry853o1#
如果要计算轮询中提取的记录数，则需要使用Consumer API，并在ConsumerRecord迭代器上使用.count()
ConsumerRecord
.count()
1条答案
按热度按时间uhry853o1#
如果要计算轮询中提取的记录数，则需要使用Consumer API，并在
ConsumerRecord迭代器上使用.count()