我有汇合平台上的aws设置有两个工人，三个Zookeeper和三个经纪人的规格。
有人能解释为什么我在kql中执行以下查询时在所有服务器都启动的情况下出现错误吗？ create STREAM SINK_STREAM WITH (VALUE_FORMAT='AVRO', KAFKA_TOPIC='sink-topic') AS select * from YP_USER_STREAM; 这里yp\u user\u流创建如下： CREATE STREAM YP_USER_STREAM (ID INT(11), EMAIL VARCHAR(64)) WITH (KAFKA_TOPIC='kafkaTopic', VALUE_FORMAT='JSON'); 此错误是在执行查询和启动ksql服务器时生成的：

[2019-07-18 09:01:45,766] INFO Retrying admin request due to retriable exception. Retry no: 1 (io.confluent.ksql.util.KafkaTopicClient:351)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
    at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
    at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
    at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)

谁能告诉我我会犯什么配置错误吗？