Ich arbeite gerade daran, ein Samza-Skript zu schreiben, das nur Daten von einem Kafka-Thema aufnehmen und die Daten zu einem anderen Kafka-Thema ausgeben wird. Ich habe eine sehr einfache StreamTask geschrieben, aber bei der Ausführung bekomme ich einen Fehler.
Der Fehler ist unten:
%Vor%Ich bin mir nicht ganz sicher, wie ich die erforderlichen Kafka-Metadaten konfigurieren oder das Skript schreiben lasse. Unten ist mein Code für die StreamTask und die Eigenschaftendatei. In der Eigenschaftendatei habe ich den Metadaten-Abschnitt hinzugefügt, um zu sehen, ob dies später im Prozess helfen würde, aber ohne Erfolg. Ist das die richtige Richtung oder fehlt mir etwas völlig?
%Vor% %Vor%Tags und Links java apache-kafka metadata apache-samza