如何使用 KafkaLoggingHandler 连接多个代理？

Question

我写的KafkaLoggingHandler如下图，如何使用KafkaLoggingHandler连接多个broker？

kafka_log_handler = KafkaLoggingHandler(
     local_kafka-1_1:9092, # ex:how can i add local_kafka-2_1??
     ...
     ...
)

这是我的 docker-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

Answer 1

您只需用逗号分隔它们

'kafka1.test.local:9095,kafka2.test.local:9096'

但是，引导协议会为您处理这个问题，因此指定多个代理的唯一原因是为了客户端容错（并且在同一台机器上运行多个代理并不能保证任何容错）