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$$
docs.aws.amazon.com/elasticsearch-service/latest/developerguide/aes-handling-errors.html)中发现,我有一个增加_cluster/settings/cluster.max_shards_per_node的选项。因此,我尝试在Kibana Dev Tools中输入以下命令 PUT /_cluster/settings "defaults" : {