运行发布订阅/从命令行Java

Question

作为每文档下https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector

卡夫卡连接器内置jar目标/ CPS-卡夫卡connector.jar

命令行上运行的Java的罐子CPS-虽然卡夫卡connector.jar

它说没有主清单属性，在CPS-卡夫卡connector.jar

我需要以运行它来创建一个单独的主类？任何人都已经为Kafka执行kafka连接器到云端酒吧？

Answer 1

查看documentation page you linked to上的“预运行步骤”和“运行连接器”步骤。你不能直接从命令行运行jar。您必须配置Kafka Connect才能使用Cloud Pub/Sub连接器，确保cps-kafka-connector.jar位于您的类路径中，然后运行Kafka Connect。 Sample configs（您需要交换项目和主题）。通过这些配置，Kafka Connect会将消息从Kafka发送到Cloud Pub/Sub（反之亦然，具体取决于使用哪种配置）。