如何在Java中获得消费者Kafka滞后

Question

我在java中有一个生产者，在nodeJS中有一个消费者。我想在 Java 中知道什么是消费者滞后，所以我知道我是否可以为该主题生成更多数据。java中的API是什么来获得消费者滞后？

Answer 1

为什么需要了解消费者滞后？代理的目的是异步生成消息。如果您需要进行同步处理，请使用基本的休息处理。