如果抵消在Kafka中被破坏了会发生什么？

Question

我们如何处理抵消腐败？

我想把偏移量日志保存在其他地方，或者拍摄偏移量的快照。我怎么能这么做？

Answer 1

Kafka将偏移量存储在名为_consumer_offsets的主题中。使用者将偏移量提交到这个主题中，并且auto.offset.reset（最早/最晚/无）的值决定从分区开始读取消息的策略。偏移量日志保留由代理属性指定。

auto.offset.reset=最新=>将从上次提交的偏移量开始读取消息，如果未找到，则将等待新消息到达并从那里开始。未引发异常

auto.offset.reset=aresty=>同样，它不会引发任何异常，如果存在偏移量，它将从头开始读取消息。

        //assign - set topic and partition you you want to read from using TopicPartion
        TopicPartition topicPartitionToReadFrom = new 
        TopicPartition(topic, 0);
        long offsetToReadFrom = 15L;
        consumer.assign(Arrays.asList(topicPartitionToReadFrom));
        
        //seek - set position of the consumer manually by calling
        //KafkaConsumer.seek(TopicPartition partition, long offset)
        consumer.seek(topicPartitionToReadFrom, offsetToReadFrom);