想象一下我们有一个
kafka cluster 有三个 nodes : 192.168.160.51 , 192.168.160.52 , 192.168.160.53 .
还有一台机器 kafka-rest , schema-registry , control-center : 192.168.160.110 .
还有一台机器
ksql service : 192.168.160.151 , 192.168.160.52 , 192.168.160.53 .
另一台机器
kafka-connect service : 192.168.160.71 , 192.168.160.72 , 192.168.160.73 .
以及 divolte 快开了 192.168.160.71 .
但是在 kafka-avro-console-consumer 总是说：

:ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$:46)
org.apache.kafka.common.errors.SerializationException: Unknown magic byte!