我编写了KafkaLoggingHandler,如下所示,如何使用KafkaLoggingHandler连接多个代理?
kafka_log_handler = KafkaLoggingHandler(
local_kafka-1_1:9092, # ex:how can i add local_kafka-2_1??
...
...
)
这是我的对接者-Compose.yml,我创建了两个由kafka图像组成的集群。
version: '2'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka-1:
image: wurstmeister/kafka
ports:
- "9095:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: kafka1.test.local
KAFKA_ADVERTISED_PORT: 9095
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_LOG_DIRS: /kafka/logs
KAFKA_BROKER_ID: 500
KAFKA_offsets_topic_replication_factor: 3
volumes:
- /var/run/docker.sock:/var/run/docker.sock
- ${KAFKA_DATA}/500:/kafka
kafka-2:
image: wurstmeister/kafka
ports:
- "9096:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: kafka2.test.local
KAFKA_ADVERTISED_PORT: 9096
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_LOG_DIRS: /kafka/logs
KAFKA_BROKER_ID: 501
KAFKA_offsets_topic_replication_factor: 3
volumes:
- /var/run/docker.sock:/var/run/docker.sock
- ${KAFKA_DATA}/501:/kafka
发布于 2021-12-24 04:38:43
你只要用逗号把它们分开
'kafka1.test.local:9095,kafka2.test.local:9096'
但是,引导协议将为您处理这个问题,因此指定多个代理的唯一原因是客户端的容错(并且在同一台机器上运行多个代理不能保证任何容错)。
https://stackoverflow.com/questions/70468977
复制相似问题