Kafka中获取消息所需耗费的时间如何计算？

在Kafka中，我们可以使用下面的代码来获取消息：

ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));

其中，Duration.ofMillis(100)参数表示消费者等待消息的最大时间，单位为毫秒。

如果你想要计算消息获取的耗费时间，可以在调用poll方法之前记录当前时间，然后再调用poll方法之后记录结束时间，并将两者相减。示例如下：

long startTime = System.currentTimeMillis(); ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); long endTime = System.currentTimeMillis(); long elapsedTime = endTime - startTime;

这里的elapsedTime就是消息获取所耗费的时间（单位为毫秒）。