卡夫卡生产者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
普利斯科
- 如何在OS X上使用Docker运行Kafka?
- 为wurstmeister / kafka docker图像定义Zookeeper znode
- kafka连接从docker挂载在本地主机上的日志
- 在部署到Docker的情况下,在Golang中实现的Apache Kafka消费者恐慌
- stream浪者箱子和docker提供者:巨人和Kafka
- 对于基于Docker容器的实现,在同一个容器中运行一对Kafka服务器和Zookeeper服务器是否有意义?
- docker和VirtualBox VM中的Apache Kafka
- 创build主题,但在Kubernetes上使用Python获取Kafka FailedPayloadsError
- Kafka无法parsingZookeper的DNS名称