我正在使用本地ksql服务器（confluent platform的最新版本），试图连接到我的服务器（aws）上的隧道kafka集群。但是，由于以下错误，我面临无法启动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版本上运行。甚至我也尝试使用与Kafka版本2.0.x兼容的ksql的早期版本（5.0.x）。然而，这个问题仍然存在。任何人遇到这个问题，请给我一个帮助。谢谢。