我如何打印Flink开始阅读的Kafka主题的每个分区的起始偏移量？
我想打印Flink已开始读取的Kafka主题的每个分区的起始偏移量？
共有1个答案
如果使用＜code＞KafkaDeserializationSchema＜/code＞来处理与＜code＞FlinkkafConsumer＜/code＞的反序列化，则＜code＞反序列化＜/code＞方法将传递一条＜code＞ConsumerRecord＜/code＞，其中包括分区和偏移量。您可以在第一次调用该方法时打印或记录。
-
我阅读了Kafka的所有文档，我读到的唯一方法是git和指定 但是为了客户的订单，我需要使用Spring，所以我的Kafkaendpoint是这样的 但是得到一个例外 无法为属性找到合适的setter：offsetRepository，因为没有具有相同类型的setter方法：java.lang.String也不可能进行类型转换：没有类型转换器可用于从类型转换：java.lang.String到所需
-
我的spring boot项目有一个演示Kafka Streams API的应用程序。我可以使用以下命令使用主题中的所有消息 Kafka Streams API中使用KStream或ktable使用消息的类似命令是什么？我试过了 两者都不起作用。我确实创建了一个测试用例，用而不是流来使用，但它不起作用。代码上传到Github以供参考。任何帮助都会很好。
-
问题内容： 在轮询Kafka时，我已经使用该功能订阅了多个主题。现在，我想设置的偏离，我想从每个主题阅读，而无需每次重新订阅后，并从一个话题。 在轮询数据之前，是否可以迭代调用每个主题名称 来 达到结果？偏移量如何精确存储在Kafka中？ 我每个主题有一个分区，并且只有一个使用者可以读取所有主题。 问题答案： Kafka如何存储每个主题的偏移量？ 卡夫卡已将抵销存储从动物园管理员转移到卡夫卡经纪人
-
我想从话题的一开始就开始消费。我已经将属性“AUTO\u OFFSET\u RESET\u CONFIG”设置为最早，但不知何故它仍然没有从一开始就读取。 如果我错过了什么，有什么想法吗？我每次都在创造一个新的消费群体。
-
如何确保我总是从Kafka主题的一开始就与Flink一起消费？ Kafka0.9。x consumer是Flink 1.0.2的一部分，它似乎不再是Kafka，而是Flink来控制偏移量： Flink在内部快照偏移量，作为其分布式检查点的一部分。Kafka/动物园管理员promise的补偿只是为了让外界对进展的看法与Flink对进展的看法保持同步。通过这种方式，监控和其他工作可以了解Flink K
-
我是 kafka 的新手，并试图了解是否有办法从上次使用的偏移量读取消息，但不是从头开始。 我正在写一个例子，这样我的意图就不会偏离。 有没有一种方法可以获取从上次使用的偏移量生成的消息。？