当前位置: 首页 > 知识库问答 >
问题:

Kafka producer错误“1个分区有领导者代理,但没有匹配的侦听器”

洪胤
2023-03-14

第一次与Kafka和多克合作。我正试图向Kafka发布一条消息,但出现了一个错误(请看下面)。问题是什么?

2020-07-21 16:37:40274警告[Kafka制作人网络线程|制作人-1]组织。阿帕奇。Kafka。客户。NetworkClient$DefaultMetadataUpdater:[Producer-clientId=Producer-1]1个分区的前导代理没有匹配的侦听器,包括[demo-topic-0]

这是我的码头工人。yml:

version: '3'

services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    links:
      - zookeeper:zk
    ports:
      - "9092:9092"
    expose:
      - "9093"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zk:2181
      KAFKA_MESSAGE_MAX_BYTES: 2000000
      KAFKA_CREATE_TOPICS: "demo-topic:1:1"
      KAFKA_BROKER_ID: 1
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9093,PLAINTEXT_HOST://localhost:9092
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
      KAFKA_LISTENERS: PLAINTEXT://kafka:9093,PLAINTEXT_HOST://localhost:9092
      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
    depends_on:
      - zookeeper

  player-service-ci:
    image: player/player-service:latest
    container_name: player-service-ci
    restart: unless-stopped
    volumes:
      - /tmp/app/logs:/logs
    environment:
      - "JAVA_OPTS=-Xmx256m -Xms128m"
      - "spring.profiles.active=ci"
      - "LOGS_FILENAME=player-service-logger-ci"
      - "SPRING_KAFKA_BOOTSTRAPSERVERS=kafka:9093"
    ports:
      - 17500:17500

networks:
  default:
    external:
      name: ci

共有1个答案

黎奇略
2023-03-14

我的问题在这里得到了部分回答,没有Kafka匹配的监听器错误。

docker-compose rm -sfv

上述代码最终解决了多个消费者的问题。

 类似资料:
  • 第一次与Kafka和Docker合作-作曲。我试图发布一个消息给Kafka,但我得到一个错误(看下面)。问题是什么?

  • 错误:分区0没有领导。跳过获取偏移量-但Description显示leader在场 请注意,consumer没有在zookeeper上写入偏移量

  • 问题内容: 我正在尝试让Kafka第一次在docker- compose上工作。该应用程序在没有docker的情况下运行良好。但是在docker上,出现如下所述的错误。卡夫卡为何会抛出此错误? 错误: email-service_1 | 2018-12-01 14:32:02.448警告1 — [ntainer#0-0-C-1] oakcNetworkClient:[Consumer client

  • 我正在努力通过SSL移动所有Kafka流量。每个区域有两个集群。 使用Kafka 2.7.0版。 除一个集群外,所有区域和所有集群都可以通过SSL正常工作。 在其他工具中,我使用< code>kafkacat来探测集群。 当通过明文连接对此集群执行时,它会列出所有代理、主题和分区,并显示每个分区的领导者: 当通过 SSL 执行相同的命令时,会发现: 0经纪人 列出主题和分区,但没有标题 对该地区的

  • 假设所有具有分区的前导和副本的节点都崩溃,并且节点不可恢复。 如何选举另一位Kafka经纪人作为该分区的领导人?(我对数据丢失感到满意) 我尝试了“kafka preferred replica election.sh”和“kafka reassign partitions.sh”,但没有成功。 设置: 两个节点kafka集群,代理ID为10和11。 具有副本因子1和分区1的主题测试。Broker

  • 我正在构建一个应用程序,其中微服务通过RabbitMQ(请求-响应模式)进行通信 一切正常,但我仍然有一个错误“远程服务中没有定义匹配的消息处理程序。”- 当我向客户端应用程序发送帖子时,它只需通过客户端(ClientProxy)发送包含数据的消息,消费者应用程序就会响应。此功能实际上可以工作,但始终只能第二次使用。我知道这听起来很奇怪,但在我的第一个POST请求中,总是有来自客户的错误,我的每一