Kafka Tüketici, aralık dışında

Question

için yapılandırılmış sıfırlama ilkesi olmadan aralık dışı ofsetler Kafka tüketicisine başlarken istisna alıyorum.

org.apache.kafka.clients.consumer.OffsetOutOfRangeException: bölümleri için yapılandırılmış sıfırlama politikası ile aralık dışında Kaydırmaları {test 0 = 29898318}

Ben Kafka sürüm 9.0 kullanıyorum .0 Java ile .0

Answer 1

Şu anda mevcut olmayan (29898318) konu (test) bölümüne (0) erişmeye çalışıyorsunuz.

bu

1. Konunuz bölümü için iki durum söz konusu olabilir 0 bu sayıda ileti olmayabilir
Mesajınız en 29898318 zaten saklama süresi tarafından silinmiş olabilir ofset

önlemek için Bunu aşağıdakilerden birini yapabilirsiniz:

1. auto.offset.reset yapılandırmasını smallest veya largest olarak ayarlayın. Sen ilişkin daha fazla bilgi bulabilirsiniz Sen Kafka komut satırı aracı aşağıdaki çalışan bir konu bölümde kullanılabilen smallest offset alabilirsiniz here
2. bu

komut: Bu yardımcı olur

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <broker-ip:9092> --topic <topic-name> --time -2 

Umut!