大佬教程收集整理的这篇文章主要介绍了为什么卡夫卡会警告“分区中的领导经纪人没有匹配的听众”?,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
如对您的问题的评论所述,问题似乎出在Kafka经纪人的广告名称上。根据您的docker-
compose,您应该使用,192.168.23.134
但您的电子邮件服务正在使用kafka:9092
。您可以尝试使用此docker-
compose。我用提供的最新Zookeeper和Kafka替换了wurstmeister服务,confluenTinc
并添加了您的电子邮件服务。
---
version: '2'
services:
zookeeper:
image: confluenTinc/cp-zookeeper:latest
environment:
ZOOKEEPER_client_port: 2181
ZOOKEEPER_TICK_TIME: 2000
kafka:
image: confluenTinc/cp-kafka:latest
depends_on:
- zookeeper
ports:
- 9092:9092
environment:
KAFKA_broKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_ListENERS: PLAIntexT://kafka:29092,PLAIntexT_HOST://localhost:9092
KAFKA_ListENER_Security_PROTOCol_MAP: PLAIntexT:PLAIntexT,PLAIntexT_HOST:PLAIntexT
KAFKA_INTER_broKER_ListENER_name: PLAIntexT
KAFKA_OFFSETS_topIC_ReplicatION_FACTOR: 1
email-service:
build: ./email-service
environment:
SPRING_KAFKA_bootstrapSERVERS: kafka:29092
ports:
- "8081:8081"
depends_on:
- kafka
请注意,它KAFKA_ADVERTISED_host_name
已被弃用,建议改为使用KAFKA_ADVERTISED_ListENERS
。有关更多信息,KAFKA_ADVERTISED_ListENERS
请在此处检查。
我正在尝试让Kafka第一次在docker-
compose上工作。该应用程序在没有docker的情况下运行良好。但是在docker上,出现如下所述的错误。卡夫卡为何会抛出此错误?
错误:
我的docker-compose配置:
version: '3.3'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka
command: [start-kafka.sh]
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_host_name: 192.168.23.134
KAFKA_create_tOPICS: "email-token:1:1"
volumes:
- /var/run/docker.sock:/var/run/docker.sock
ports:
- "9092:9092"
depends_on:
- zookeeper
email-service:
build: ./email-service
environment:
SPRING_KAFKA_BOOTSTRAPSERVERS: kafka:9092
ports:
- "8081:8081"
depends_on:
- kafka
以上是大佬教程为你收集整理的为什么卡夫卡会警告“分区中的领导经纪人没有匹配的听众”?全部内容,希望文章能够帮你解决为什么卡夫卡会警告“分区中的领导经纪人没有匹配的听众”?所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。