Kafka0.9：从最早的Kafka偏移量消费

Question

enable.auto.commit = false
auto.offset.reset = earliest

相反，我需要做的是将group.id更改为新的内容，然后它将从最早的偏移量恢复。

会不会有其他的犯罪行为？

更新

if (endpoint.isAutoCommitEnable() != null && !endpoint.isAutoCommitEnable()) {
    if (processed >= endpoint.getBatchSize()) {
        consumer.commitSync();
        processed = 0;
    }
}

根据我的理解，这看起来像是每次auto commit enable为false时，它都将提交偏移量。这是Camel Kafka组件的一个特性，因为即使启用了自动提交，它也将在x条消息之后同步

Answer 1

你的理解听起来是正确的。

Kafka0.9有“旧”和“新”消费者配置。此配置属性在它们之间发生了更改。

auto.commit.enable = false
enable.auto.commit = false

https://kafka.apache.org/documentation#ConsumerConfigs

2016-10-06 14:19:41,725 INFO [org.apache.kafka.clients.consumer.ConsumerConfig:165] - ConsumerConfig values:
    group.id = service
    bootstrap.servers = [kafka:9092]
    enable.auto.commit = false
    auto.offset.reset = latest