我们已将邮件推送到kafka队列2天前，保留时间设置为2天，因此将在今天过期。有没有办法确切地知道Kafka队列什么时候是空的/里面没有任何数据？我是hadoop系统的初学者，所以我不知道是否有任何命令可以找到这个/简单的方法来验证空队列
xpszyzbs1#
你可以使用 KafkaConsumer 薰衣草 seekToEnd() , seekToBeginning() ，和 position() 获取每个分区的最小和最大偏移量。如果所有分区都匹配，则主题为空。
KafkaConsumer
seekToEnd()
seekToBeginning()
position()
1条答案
按热度按时间xpszyzbs1#
你可以使用
KafkaConsumer薰衣草seekToEnd(),seekToBeginning()，和position()获取每个分区的最小和最大偏移量。如果所有分区都匹配，则主题为空。