KSQL Server подключается к удаленному кластеру Kafka - PullRequest
Новая
       14

KSQL Server подключается к удаленному кластеру Kafka

0 голосов
/ 19 марта 2019

Я использую локальный сервер KSQL (последняя версия Confluent Platform), пытаюсь подключиться к кластеру Tunneled Kafka на моем сервере (AWS).Тем не менее, я столкнулся с проблемой не могу запустить сервер KSQL из-за ошибки ниже: 

ERROR Failed to initialize TopicClient: Unexpected broker id, expected 5 or empty string, but received ConfigResource(type=BROKER, name='1').name (io.confluent.ksql.services.KafkaTopicClient:279)
ERROR Failed to start KSQL (io.confluent.ksql.rest.server.KsqlServerMain:53)
io.confluent.ksql.util.KsqlException: Could not fetch broker information. KSQL cannot initialize
    at 
io.confluent.ksql.services.KafkaTopicClientImpl.isTopicDeleteEnabled (KafkaTopicClientImpl.java:280)
    at io.confluent.ksql.services.KafkaTopicClientImpl.<init>(KafkaTopicClientImpl.java:66)
    at io.confluent.ksql.services.DefaultServiceContext.create(DefaultServiceContext.java:43)
    at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:303)
    at io.confluent.ksql.rest.server.KsqlServerMain.createExecutable(KsqlServerMain.java:85)
    at io.confluent.ksql.rest.server.KsqlServerMain.main(KsqlServerMain.java:50)
Caused by: org.apache.kafka.common.errors.InvalidRequestException: Unexpected broker id, expected 5 or empty string, but received ConfigResource(type=BROKER, name='1').name

Мой туннельный кластер kafka работает на версии 2.0.0.Даже я пытался использовать предыдущую версию KSQL (5.0.x), которая совместима с версией Kafka 2.0.x.Однако проблема все еще случается.Кто-нибудь сталкивался с проблемой, пожалуйста, дайте мне помощь.Спасибо.

...