Tag: scalability

卡夫卡生产者configuration和docker工人

我对卡夫卡有个疑问： 我正在使用Docker运行Kafka以下configuration kafka: image: wurstmeister/kafka ports: – "9092:9092" links: – zookeeper:zk environment: KAFKA_CREATE_TOPICS: "mytopic:1:1" KAFKA_ADVERTISED_HOST_NAME: ${DOCKER_HOST_IP} KAFKA_ADVERTISED_PORT: "9092" KAFKA_ZOOKEEPER_CONNECT: "zk:2181" volumes: – /var/run/docker.sock:/var/run/docker.sock 所以我只是创build一个运行在9092端口的实例。 我的问题是：据我所知，当扩展时，卡夫卡的其他实例在不同的端口上运行，但我的制片人仍然在端口9092运行..我假设这样，如果第一个实例确定卡夫卡由于某种原因死亡，因为KafkaProducer刚刚在9092上运行，所以我无法生成消息： self.producer = KafkaProducer(bootstrap_servers='kafka:9092',api_version=(0,10)) 我怎么解决这个问题？ TKS 普利斯科