首页 > 解决方案 > 无法使用 conduktor 连接到 kafka?

问题描述

我使用以下撰写文件在 VM Ubuntu 18.0.4 上安装了 Kafka

version: '2'

networks:
  kafka-net:
    driver: bridge

services:
  zookeeper-server:
    image: 'bitnami/zookeeper:latest'
    networks:
      - kafka-net
    ports:
      - '2181:2181'
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka-server1:
    image: 'bitnami/kafka:latest'
    networks:
      - kafka-net    
    ports:
      - '9092:9092'
    environment:
      - KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181
      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://:9092
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper-server
  kafka-server2:
    image: 'bitnami/kafka:latest'
    networks:
      - kafka-net    
    ports:
      - '9093:9092'
    environment:
      - KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181
      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://:9093
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper-server

它安装没有任何问题。

sudo docker container ls

CONTAINER ID        IMAGE                      COMMAND                  CREATED             STATUS              PORTS                                                  NAMES
39f38caf57cb        bitnami/kafka:latest       "/entrypoint.sh /run…"   3 hours ago         Up 5 minutes        0.0.0.0:9092->9092/tcp                                 kafka_kafka-server1_1
088a703b5b76        bitnami/kafka:latest       "/entrypoint.sh /run…"   3 hours ago         Up 3 hours          0.0.0.0:9093->9092/tcp                                 kafka_kafka-server2_1
6a754bda47ea        bitnami/zookeeper:latest   "/entrypoint.sh /run…"   3 hours ago         Up 3 hours          2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp, 8080/tcp   kafka_zookeeper-server_1

现在,我想使用以下设置连接到我的 VM 上的 Kafka:

卡夫卡指挥

我使用以下命令从本地主机测试它

root@ubuntu:~# kafkacat -b 192.168.179.133:9092 -L
Metadata for all topics (from broker -1: 192.168.179.133:9092/bootstrap):
 1 brokers:
  broker 1001 at localhost:9092
 0 topics:

但在我的 Windows 10 中,我无法使用Conduktor连接到 192.168.179.133:9092

如您所见,它返回错误。
测试 ZK 可以,但测试 kafka Connectivity 会引发错误!

标签: dockerapache-kafka

解决方案


KAFKA_CFG_ADVERTISED_LISTENERS如果您的指挥未安装在与安装 Kafka 集群的同一台机器上,您应该进行更改。

kafka-server1 应该是这样的:

KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://192.168.179.33:9092

和卡夫卡服务器2:

KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://192.168.179.33:9093

注意:您应该考虑在导体中添加两个 kafka 服务器以实现冗余。

您可以查看以获取更多信息。


推荐阅读