ich einen kafka Verbraucher die neue API erstellt habe (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)kafka individuelle Verbraucher eingehende Datensätze lesen
Zur Zeit die Verbraucher lesen die Nachrichten aus dem Thema Lesen aus dem Offset kleinsten beginnen. Ich möchte dies überschreiben, um vom letzten Offset zu lesen. Gibt es Hinweise darauf, wie das gemacht werden kann?
Sobald Sie mit dem Lesen von Nachrichten für eine bestimmte Verbrauchergruppe begonnen haben, müssen Sie den Verbraucher mit der seekToEnd() -Methode explizit zum Ende der Partitionen zwingen, die er verfolgt. Für Verbrauchergruppen, die noch keine Nachrichten gelesen haben, können Sie die Eigenschaft auto.offset.reset = largest verwenden, um dem Verbraucher mitzuteilen, wo er seine erste Nachricht lesen soll.
Versuchen Sie auto.offset.reset = largest einzustellen, obwohl dies die Standardeinstellung sein sollte.