Запуск PubSub/Kafka-разъем из командной строки Java

Question

В соответствии с документацией под https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector

Встроенный целевой банку/сП-Кафка-connector.jar

Во время работы в командной строке, как Java -jar cps- Кафка-connector.jar

Это говорит не главный атрибут манифеста, в сП-Кафки-connector.jar

Мне нужно создать отдельный основной класс для того, чтобы запустить его? Кто-нибудь выполнил кафка-коннектор для Кафки, чтобы облако паба?

Answer 1

Взгляните на «Предварительные шаги» и шаги «Выполнение коннектора» на documentation page you linked to. Вы не можете запустить банку непосредственно из командной строки. Вы должны настроить Kafka Connect для использования соединителя Cloud Pub/Sub, убедитесь, что cps-kafka-connector.jar находится в вашем пути к классу, а затем запустите Kafka Connect. Sample configs (где вам нужно поменять свой проект и темы). С помощью этих конфигураций Kafka Connect отправит сообщения от Kafka в Cloud Pub/Sub (или наоборот, в зависимости от того, какая конфигурация используется).