验证Kafka队列是否为空

Question

我们已经将消息推送到两天前的kafka队列中，保留时间设置为2天，所以它将在今天到期。有没有办法确切地知道kafka队列何时为空/其中没有任何数据？

我是Hadoop系统的初学者，所以我不知道是否有什么命令可以找到这个/验证空队列的简单方法

Answer 1

您可以使用KafkaConsumer laveraging seekToEnd()、seekToBeginning()和position()编写自己的小工具来获取每个分区的最小和最大偏移量。如果所有分区都匹配，则该主题为空。