Lauf PubSub/kafka-Stecker von der Kommandozeile java

Question

Gemäß der Dokumentation unter https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector

Built das Glas Target/cps-kafka-connector.jar

Während auf Befehlszeile als java -jar CPS- läuft kafka-connector.jar

es sagt kein Haupt manifest-Attribut, in cps-kafka-connector.jar

Benötige ich eine separate Hauptklasse zu schaffen, um es auszuführen? Hat jemand Kafka-Connector für Kafka zum Cloud Pub ausgeführt?

Answer 1

Werfen Sie einen Blick auf die Schritte "Pre-Running Steps" und "Running a Connector" auf der documentation page you linked to. Sie können das JAR nicht direkt über die Befehlszeile ausführen. Sie müssen Kafka Connect konfigurieren, um den Cloud Pub/Sub-Konnektor zu verwenden, stellen Sie sicher, dass sich cps-kafka-connector.jar in Ihrem Klassenpfad befindet, und führen Sie dann Kafka Connect aus. Sample configs (wo Sie in Ihrem Projekt und Themen austauschen müssen) zur Verfügung gestellt werden. Mit diesen Konfigurationen sendet Kafka Connect Nachrichten von Kafka an Cloud Pub/Sub (oder umgekehrt, je nachdem, welche Konfiguration verwendet wird).