Thema Offset auf Wert für alle Verbraucher zurück setzen

Question

Ich habe mehrere Verbraucher abonniert zu einem Thema und alle von ihnen sind in der gleichen Gruppe. Manchmal ist es notwendig, alle Verbraucher zu zwingen, einige Daten, die sie bereits verarbeitet haben, erneut zu verarbeiten. In diesem Fall habe ich genau die Zeit, um die Verbraucher-Offsets einzustellen.

Frage: Gibt es in Kafka einen Mechanismus, um alle Verbraucherversätze auf bestimmte Zeit einzustellen? Hier meine ich, dass Verbraucher nicht neu gestartet werden müssen, nur ihre Offsets sollten magisch auf einen neuen Wert gesetzt werden und die nächsten Poll-Anfragen würden von neuem Offset beginnen.

Wenn es mit Standard-Kafka unmöglich ist, gibt es irgendwelche fertigen Bibliotheken, die solch einen Mechanismus bereitstellen?

Answer 1

Wahrscheinlich suchen Sie nach einer seek Methode:

public void seek(TopicPartition partition, long offset) 

Überschreibungen der Abruf- Offsets, dass der Verbraucher auf der nächsten Umfrage (Timeout) verwendet ...