如何获得Kafka主题分区的最后/结束偏移量？
现在我的问题是如何得到一个主题的结束偏移量，有人说我可以用老消费者，但是太复杂了，新消费者有这个功能吗？
共有1个答案
新的消费者也是复杂的。
//分配主题使用者。assign（）；
//查找主题使用者的结尾。SeekToEnd（）；
-
问题内容： 我正在使用Java 编写使用者。我想保持消息的实时性，因此，如果有太多消息在等待使用，例如1000条或更多，我应该放弃未使用的消息，并从最后一个偏移量开始使用。 对于此问题，我尝试比较主题的最后提交的偏移量和主题的结束偏移量（仅1个分区），如果这两个偏移量之间的差大于某个值，则将主题的最后提交的偏移量设置为下一个偏移量，这样我就可以放弃那些多余的消息。 现在我的问题是如何获得主题的最终
-
我有一个问题，假设有一个TOPIC T1，有两个消费者C1和C2属于两个不同的组，电流偏移量是0.我们知道Kafka维护消费者的偏移量。因此，如果 C1 使用消息并且 Offset 变为 1，那么如果 C2 使用消息，它将从 1 偏移量开始，还是从 0 偏移量开始使用消息，会发生什么情况？表示两个不同的消费群体将如何维持抵消？ 谢啦
-
问题内容： 在轮询Kafka时，我已经使用该功能订阅了多个主题。现在，我想设置的偏离，我想从每个主题阅读，而无需每次重新订阅后，并从一个话题。 在轮询数据之前，是否可以迭代调用每个主题名称 来 达到结果？偏移量如何精确存储在Kafka中？ 我每个主题有一个分区，并且只有一个使用者可以读取所有主题。 问题答案： Kafka如何存储每个主题的偏移量？ 卡夫卡已将抵销存储从动物园管理员转移到卡夫卡经纪人
-
Kafka主题分区偏移位置始终从0或随机值开始，如何确保使用者记录是分区中的第一条记录？有没有办法找出答案？如果有的话，请让我知道。谢谢。
-
我试图阅读上一篇文章中的Kafka主题，但我无法正确阅读： 在属性文件中，我设置了以下内容： 组id=我的团队 客户。id=my_client 启用。汽车提交=真 自动。抵消重置=最早的 隔离。级别=读取已提交 然后代码： 我可以看到偏移量是如何从0打印出来的，即使我在主题中有一些项目。 在日志文件中，我可以看到以下内容（缩写）： [Consumer clientId=my_client，grou
-
问题内容： 如何从代码中获取任何kafka主题的分区数。我研究了许多链接，但似乎没有一个起作用。 提及一些： http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count- through-simpleclient-api http://grokbase.com/t/kafka/users/151cv3htga/ge