Ich benutze derzeit Windows-Maschine und in der Lage, ganze Datei über die Eingabeaufforderung mit Kafka Produzent und Verbraucher zu lesen. Ich brauche nur die letzten Änderungen in einer Datei und muss sie als Eingabe für Apache flink verwenden. Ich habe versucht, this link, aber aufgrund kafka Client jar Mismatch Problem, ich war nicht in der Lage, es zu verwenden.So lesen Sie nur neue Änderungen aus einer Datei mit Kafka Produzent
In meinem aktuellen Ansatz, wenn ich meinen Hersteller jedes Mal aufrufen, lädt es die gesamte Datei und wir müssen es jedes Mal ausführen, um die Änderungen in der Datei aufgetreten zu sehen. Ich dachte über die Verwendung von Threads und eine Möglichkeit, Unterschiede in Dateien mit Java-Code zu vergleichen, aber gibt es nur Kafka.