Kafka监听器在融合的kubernetes设置中是错误的

Question

我无法从外部连接到我的kafka群集。听众和公告的听众似乎有问题。

有什么建议吗？

当我尝试从外部在端口30092上进行连接时，我总是会获得对kafka-svc：9092的引用。

• 集群名称：dev-docker-x02
• 我如何测试：Windows的默认kafka：。\ bin \ windows \ kafka-topics.bat --list --bootstrap-server dev-docker-x02：30092
• 要求：使用confluentinc / cp-kafka：5.4.0-1-ubi8

我的设置：

我的代理配置（问题似乎出在（播发的）侦听器中。

kind: Deployment
metadata:
  name: kafka-deploy
spec:
  replicas: 1
  selector:
    matchLabels:
        app: kafka-pod
  template:
    metadata:
      labels:
        app: kafka-pod
    spec:
      containers:
      - name: kafka-ctr         # Container name
        image: confluentinc/cp-kafka:5.4.0-1-ubi8
        ports:
        - containerPort: 9092   # Port exposed by the container
        env:
        - name: KAFKA_BROKER_ID
          value: "0"
        - name: KAFKA_ZOOKEEPER_CONNECT
          value: zookeeper-svc:2181
        - name: KAFKA_LISTENERS
          value: "LISTENER_INTERNAL://:9092,LISTENER_EXTERNAL://:30092"
        - name: KAFKA_ADVERTISED_LISTENERS
          value: "LISTENER_INTERNAL://kafka-svc:9092,LISTENER_EXTERNAL://dev-kube-x02:30092"
        - name: KAFKA_LISTENER_SECURITY_PROTOCOL_MAP
          value: "LISTENER_INTERNAL:PLAINTEXT,LISTENER_EXTERNAL:PLAINTEXT"
        - name: KAFKA_INTER_BROKER_LISTENER_NAME
          value: "LISTENER_EXTERNAL"
        - name: KAFKA_AUTO_CREATE_TOPICS_ENABLE
          value: "false"
        - name: KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR
          value: "1"
        - name: KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS
          value: "100"

我无法从外部连接到我的kafka群集。侦听器和公告的侦听器似乎存在问题。有什么建议么？当我尝试从外部在端口30092上进行连接时，...

Answer 1

如果使用Confluent Helm Charts并在那里阅读文档，则可以为远程侦听器配置不同的功能选项。

Answer 2

Kafka有很多组件，例如Headless Services，Statefulsets，每个组件都有独特的作用。因此，我也建议使用Kafka Confluentic Helm Chart。