我主要使用 Kafka 进行传统消息传递，但我也希望能够以批量方式使用小主题，即连接到一个主题，使用所有消息并立即断开连接(不阻止等待新消息) 。我的所有主题都有一个分区(尽管它们是跨集群复制的)，如果可能的话，我想使用高级使用者。从文档中并不清楚我如何在 Scala(或 Java)中完成这样的事情。非常感谢任何建议。
最佳答案
如果之前没有消费任何消息，consumer.timeout.ms 设置将在指定时间后抛出超时异常，据我所知，这是高级消费者的唯一选择。使用此功能，您可以将其设置为 1 秒之类的值，如果这是可接受的解决方案，则在此之后断开连接。
如果没有，您必须使用简单的消费者并检查消息偏移量。
关于java - 消耗掉所有 Kafka 主题然后立即断开连接？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31324352/