:193)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run:复制因子:3大于可用代理:1.\n\t tat org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureIm
(StreamTask.java:203) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:527)
Causedby: org.apache.kafka.streams.errors.