Przesunięcia konsumenta Kafki poza zasięgiem bez skonfigurowanej zasady resetowania dla partycji

Question

Otrzymuję wyjątek, gdy startuje konsument Kafka.

org.apache.kafka.clients.consumer.OffsetOutOfRangeException: Przesunięcia poza zasięgiem bez skonfigurowanej polityki resetu dla partycji {test-0 = 29898318}

Używam Kafka wersji 9.0 .0 z Java 7.

Answer 1

Próbujesz uzyskać dostęp do przesunięcia (29898318) w temacie (test) partycji (0), która jest obecnie niedostępna.

Nie może być dwa przypadki tej

1. partycji tematu 0 nie mogą mieć te wiele wiadomości
2. Twoja wiadomość w offsecie 29898318 może już usunięte przez okres retencji

Aby uniknąć możesz wykonać jedną z następujących czynności:

1. Ustaw auto.offset.reset config na smallest lub largest. można znaleźć więcej informacji dotyczących tego here
2. Można uzyskać smallest offset dostępne dla partycji tematu przez biegania po Kafka narzędziem wiersza poleceń

polecenie:

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

Nadzieja to pomaga!