共有1个答案
没有特定的API来计算来自主题的记录数。您需要消费并计算您从kafka Consumer收到的记录的数量。
-
我使用的是0.9.0.0版本的Kafka，我想在不使用管理脚本Kafka-console-consumer.sh的情况下计算主题中的消息数。 我已经尝试了答案Java“How to get number of messages in a topic in apache kafka”中的所有命令，但都没有结果。有人能帮我吗？
-
我需要一个Kafka主题存储的消息数量。这与任何消费者是否消费了消息无关。 以上是否等于Kafka主题中当前存储的消息数？
-
我创建了一个制作人和一个消费者，使用“Kafka节点”包发送和消费Kafka主题的消息。生产者和消费者通过API进行调用。POST方法用于向主题发送消息，而GET方法用于在消费者处从主题获取消息。 当我向KAFKA发送消息后调用consumer API时，之前的所有消息都会在。 我只需要最后一条消息，这是生产者发送的。 如何在不使用任何数组或任何东西的情况下获取最后一条消息。 有没有办法删除这个话
-
我正在寻找一种从Kafka主题中删除（完全删除）已消费记录的方法。我知道有几种方法可以做到这一点，例如更改主题的保留时间或删除Kafka logs文件夹。但我要寻找的是一种使用Java API删除某个主题的一定数量记录的方法，如果可能的话。 我试过测试AdminClient API，特别是AdminClient。deleteRecords（recordsToDelete）方法。但如果我没弄错的话，
-
我们正在使用带有Datatorrent的Apache kafka来处理消息。有没有办法从shell命令行检查kafka主题中没有消息？ 谢啦
-
我试图了解如何跟踪Kafka的信息摄取。 我们现在遵循的工作流程是清除主题中的所有消息，然后我们用代码更改重新摄取。我需要知道那些代码更改有多成功。在当前状态下，我正在使用Kafka工具，手动刷新消息总数，并将结果保存在csv中，我知道这是不可持续的长期。 你对自动获取Kafka主题中的消息计数有什么建议？理想情况下，我想击中的主题一分钟一分钟的频率，并得到计数，以及窗口的时间，如1天等。