0

我正在尝试设置 mirrormaker 。我已经将mirrormaker进程停靠了起来。我有两个 kafka 集群在同一台机器上运行。

卡夫卡码头工人在下面

version: '2.1'
services:
  zookeeper:
    image: bitnami/zookeeper:3.6.1-debian-10-r41
    ports:
      - "2181:2181"
    environment: 
      ALLOW_ANONYMOUS_LOGIN: "yes"  
      
  kafka:
    image: bitnami/kafka:2.5.0-debian-10-r63
    container_name: kafka
    depends_on:
      - "zookeeper"
    ports:
      - "9092:9092"
    environment:
      DOCKER_API_VERSION: 1.22
      KAFKA_ADVERTISED_HOST_NAME: 10.128.0.34
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://10.128.0.34:9092
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_BROKER_ID: 1
      KAFKA_CREATE_TOPICS: "test"
      KAFKA_ADVERTISED_PORT: 9092
      ALLOW_PLAINTEXT_LISTENER: "yes"
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

第二个卡夫卡码头工人

version: '2.1'
services:
  zookeeper1:
    image: bitnami/zookeeper:3.6.1-debian-10-r41
    ports:
      - "2182:2181"
    environment: 
      ALLOW_ANONYMOUS_LOGIN: "yes"
  
  kafka1:
    image: bitnami/kafka:2.5.0-debian-10-r63
    container_name : kafka1
    depends_on:
      - "zookeeper1"
    ports:
      - "9093:9092"
    environment:
      DOCKER_API_VERSION: 1.22
      KAFKA_ADVERTISED_HOST_NAME: 10.128.0.34
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://10.128.0.34:9093
      KAFKA_ZOOKEEPER_CONNECT: zookeeper1:2181
      KAFKA_BROKER_ID: 1
      KAFKA_CREATE_TOPICS: "test"
      KAFKA_ADVERTISED_PORT: 9093
      ALLOW_PLAINTEXT_LISTENER: "yes"
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

如您所见，一个正在运行9092，另一个正在运行9093

我有consumer.properties如下

bootstrap.servers=10.128.0.34:9092
group.id=my-test-app
exclude.internal.topics=true
#mirror.topics.whitelist=test
client.id=my-test-app
partition.assignment.strategy=org.apache.kafka.clients.consumer.RangeAssignor

producer.properties如下_

bootstrap.servers=10.128.0.34:9093
acks=1
batch.size=100
client.id=my-test-app
partition.assignment.strategy=org.apache.kafka.clients.producer.RangeAssignor

当我尝试向 发布消息时kafka on 9092，出现以下错误

KafkaJSProtocolError: The group member's supported protocols are incompatible with those of existing members","groupId":"my-test-app","stack":"KafkaJSProtocolError: The group member's supported protocols are incompatible with those of existing members

有人可以帮我解决这个问题。如果需要，请向我询问更多详细信息

4

0 回答 0