server -bootstrap在host1和host2上,我使用--cluster-store和--cluster-advertise修改了守护进程选项,并重新启动了docker daemon。host1
DOCKER_OPTS="--cluster-store=consul://<manager>:8500 --clust
:9092"), )Exception in thread "main" java.lang.ClassCastException: kafka.cluster.BrokerEndPointcannot be cast to kafka.cluster.Broker
at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$