使用来自 Kafka 主题分区的消息，该消息来自偏移量/自动提交设置为 true 的日期

Question

依赖使用阿尔帕卡Kafka3.0

我们有以下消费者设置。

enable.auto.commit = true

自动偏移。reset=最早

如果我们有enable.auto.commit = true，那么是否有可能从特定的偏移量/日期消费来自Kafka主题分区的消息？

Answer 1

使用< code>assign方法，而不是< code>subscribe方法

 public void sample() {
        KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(properties);
        TopicPartition partition = new TopicPartition("some-topic", 0);
        consumer.assign(Arrays.asList(partition));
        consumer.seek(partition, 0);
        while (true) {
            final ConsumerRecords<Long, String> consumerRecords = consumer.poll(1000);
        }
    }

据我所知，当您使用赋值方法而不是订阅方法时，没有必要在消费者属性中指定消费者组，因此可能会忽略这些参数（启用.auto.commit，auto.offset.reset）。使用 assign 方法并仅出于调试或测试目的进行搜索。

还有另一个叫做offsetsForTimes的方法来获得想要寻找的偏移量。