如何检查模式注册表群集以及如何使用docker组合设置群集模式

Question

我制作了一个坞-撰写文件来设置Kafka和模式注册表。但是，我无法检查模式注册表集群是否运行良好。

如何检查架构注册表群集模式？

我的坞-撰写文件作为集群运行良好吗？我不确定它的效果是否好。我只能看到两个卡夫卡和两个注册表在运行。

这是我的拼图文件。

version: '2'
services:
  zookeeper:
    image: zookeeper:3.7.0
    container_name: zookeeper-ri
    ports:
      - "2181:2181"
  kafka1:
    image: confluentinc/cp-kafka:7.0.1
    container_name: kafka-1
    ports:
      - "9091:9091"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 2
      KAFKA_LISTENERS: "INTERNAL://kafka1:19091, EXTERNAL://:9091"
      KAFKA_ADVERTISED_LISTENERS: "INTERNAL://kafka1:19091, EXTERNAL://localhost:9091"
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: "INTERNAL:PLAINTEXT, EXTERNAL:PLAINTEXT"
      KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
      KAFKA_BROKER_ID: 1
    depends_on:
      - zookeeper
  kafka2:
      image: confluentinc/cp-kafka:7.0.1
      container_name: kafka-2
      ports:
        - "9092:9092"
      environment:
        KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
        KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 2
        KAFKA_LISTENERS: "INTERNAL://kafka2:19092, EXTERNAL://:9092"
        KAFKA_ADVERTISED_LISTENERS: "INTERNAL://kafka2:19092, EXTERNAL://localhost:9092"
        KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: "INTERNAL:PLAINTEXT, EXTERNAL:PLAINTEXT"
        KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
        KAFKA_BROKER_ID: 2
      depends_on:
        - zookeeper
  
  kafka-ui:
    image: provectuslabs/kafka-ui
    container_name: kafka-ui
    depends_on:
      - kafka1
      - kafka2
      - zookeeper
      - schema-registry1
    ports:
      - "8083:8080"
    restart: always
    environment:
      - KAFKA_CLUSTERS_0_NAME=local
      - KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=kafka1:19091, kafka2:19092
      - KAFKA_CLUSTERS_0_ZOOKEEPER=zookeeper:2181
      - KAFKA_CLUSTERS_0_SCHEMAREGISTRY=http://schema-registry1:8085,http://schema-registry2:8086

  schema-registry1:
    image: confluentinc/cp-schema-registry:6.2.0
    restart: always
    container_name: registry-1
    depends_on:
      - kafka1
      - kafka2
    environment:
      - SCHEMA_REGISTRY_HOST_NAME=schema-registry-1
      - SCHEMA_REGISTRY_LISTENERS=http://0.0.0.0:8085
      - SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS=PLAINTEXT://kafka1:19091,PLAINTEXT://kafka2:19092
    ports:
      - 8085:8085

  schema-registry2:
    image: confluentinc/cp-schema-registry:6.2.0
    restart: always
    container_name: registry-2
    depends_on:
      - kafka1
      - kafka2
    environment:
      - SCHEMA_REGISTRY_HOST_NAME=schema-registry-2
      - SCHEMA_REGISTRY_LISTENERS=http://0.0.0.0:8086
      - SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS=PLAINTEXT://kafka1:19091,PLAINTEXT://kafka2:19092

    ports:
      - 8086:8086

Answer 1

只有一个架构注册表实例可以在任何时候对_schemas主题进行操作。因此，您可以启动该主题的使用者，然后尝试注册两个单独的模式，但每个注册表实例都注册一个模式。如果其中一个失败了，而另一个成功了，那么你就有了一个领导人选举问题。

例如，您可能需要查看master.eligibility配置选项。