我有一个Kafka消费者，配置如下
enable.auto.commit : true
max.poll.records: 50
auto.commit.interval.ms : 10000消费者方法如下，
@KafkaListener(topics = ("my-topic"),groupId = ("groupId"),
containerFactory = "listenerContainerFactory",concurrency = 2 ,autoStartup = "true")
public void myListener(@Payload String message) {
System.out.println("Received Message : " + message);
// do some heavy processing
}我知道SpringKafka一次将获取50条消息（max.poll.records），并使用两个线程来处理这些消息（concurrency=2）。
现在我要知道完成这批货要花多少时间。这意味着20条消息有两个线程。
我可以把我的记录器放在哪里得到这些信息？
1条答案
按热度按时间rxztt3cl1#
它最多能卖50英镑（不总是50英镑）。
您可以使用测微计度量每个消息的侦听器性能。
从版本2.3开始，如果在类路径上检测到测微计，并且应用程序上下文中存在单个测微计注册表，则侦听器容器将自动为侦听器创建和更新测微计计时器。
我们目前不测量处理整个批次的时间。