我正在Kafka制作人的表演中玩耍。我需要通过调整批处理大小来减少kafka生产者发送给kafka集群的请求数。我使用2分钟的批处理
我试着打印中提到的指标https://kafka.apache.org/documentation/. 但是没有具体的度量来统计kafka生产者向kafka集群发送请求的数量。
预期结果：
我需要测量Kafka生产者执行呼叫或通话Kafka集群发送记录的次数。如果kafka花更多的时间在集群上，那么我可以调整linger.ms和batch size
我正在Kafka制作人的表演中玩耍。我需要通过调整批处理大小来减少kafka生产者发送给kafka集群的请求数。我使用2分钟的批处理
我试着打印中提到的指标https://kafka.apache.org/documentation/. 但是没有具体的度量来统计kafka生产者向kafka集群发送请求的数量。
预期结果：
我需要测量Kafka生产者执行呼叫或通话Kafka集群发送记录的次数。如果kafka花更多的时间在集群上，那么我可以调整linger.ms和batch size
1条答案
按热度按时间syqv5f0l1#
您应该能够使用文档中提到的一些生产者度量来获得度量。
你可以用
request-total. 如果您在2分钟窗口开始之前以及知道生产者向集群发送了多少请求之后获得该值。如果生产者正在批处理，则请求可以包含多条记录。还有
record-send-total对于实际记录计数和outgoing-byte-total用于字节计数。所有这些指标也以速率（平均每秒）的形式存在。
这应该足以实现你想要的。