Ich habe ein Problem festgestellt, bei dem alle meine Nachrichten in meinem Thema von meinem Kunden erneut gelesen werden. Ich habe nur 1 Verbraucher, und ich schalte es ein/aus, während ich entwickle/teste. Ich merke, dass manchmal nach Tagen, in denen der Verbraucher nicht läuft, wenn ich ihn wieder einschalte, plötzlich alle meine Nachrichten erneut gelesen werden.Kafka Consumer Nachrichten erneut lesen
Die clientid und groupid bleiben durchgehend gleich. Ich rufe commitSync explizit auf, da meine enable.auto.commit = false ist. Ich setze auto.offset.reset = am frühesten, aber zu meinem Verständnis sollte das nur einspringen, wenn der Offset auf dem Server gelöscht wird. Ich verwende den MessageHub-Dienst von IBM Bluemix. Vielleicht löscht das also automatisch einen Offset?
Hat jemand irgendwelche Hinweise/Ideen?
Danke.
Oh ich sehe, ich habe die Einstellung auch gefunden, offsets.retention.minutes. Ist das in bluemix für den Broker konfigurierbar? Vielen dank für Deine Hilfe! – kyl
Im Moment ist es nicht konfigurierbar. Obwohl das Kafka-Protokoll es erlaubt, eine Verweilzeit beim Offsets festzulegen, ist diese Funktionalität in den Clients nicht verfügbar. –