Mit der Java-Bibliothek des Kafka-Clients hat die Verwendung von Protokollen eine Zeit lang funktioniert, aber mit den folgenden Fehlern funktioniert sie nicht mehr:
%Vor%Es wird zurückgesetzt.
Beim Ausführen einer anderen Instanz derselben Anwendung werden sofort Fehler angezeigt.
Ich vermute, dass Kafka oder sein ZooKeeper ein Problem hat, aber es gibt kein Fehlerprotokoll.
Wer hat eine Vorstellung davon, was hier vor sich geht?
Dies ist die Anwendung, die ich verwende: Ссылка
Ich hatte gerade das gleiche Problem. Ich habe untersucht, und in diesen Thread und in dieses Wiki können Sie die Lösung finden.
Das Problem scheint zu sein, dass die Verarbeitung eines Stapels länger dauert als das Sitzungszeitlimit. Erhöhen Sie entweder das Sitzungszeitlimit oder die Abfragehäufigkeit oder begrenzen Sie die Anzahl der empfangenen Bytes.
Was für mich funktioniert hat, war max.partition.fetch.bytes zu ändern. Sie können aber auch session.timeout.ms oder den Wert ändern, den Sie an Ihre consumer.poll(TIMEOUT)
Tags und Links java apache-kafka kafka-consumer-api