回答

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(反之亦然,具體取決於使用哪種配置)。