java 连接 docker kafka环境报错

ゝ一纸荒年。 2023-06-08 10:58 1阅读 0赞

编辑 docker-compose.yml ，要使外网能访问docker内部的kafka，

KAFKA\_ADVERTISED\_LISTENERS: PLAINTEXT://kafka001:9092，这个配置是关键

docker-compose.yml ：

version: '2'  
services:  
  zookeeper:  
    image: wurstmeister/zookeeper  
    ports:  
      - "2181:2181"  
  kafka:  
    image: wurstmeister/kafka  
    ports:  
      - "9092:9092"  
    environment:  
      KAFKA\_ADVERTISED\_LISTENERS: PLAINTEXT://:9092  
      KAFKA\_LISTENERS: PLAINTEXT://:9092  
      KAFKA\_ADVERTISED\_LISTENERS: PLAINTEXT://kafka001:9092  
      KAFKA\_ZOOKEEPER\_CONNECT: zookeeper:2181  
    volumes:  
      - /var/run/docker.sock:/var/run/docker.sock

启动之后会提示无法连接kafka001:9092的错误，docker ps查看容器id

docker exec -it  容器id /bin/bash,进入容器，编辑hosts指定ip

\#vi hosts

192.168.100.22  kafka001

保存后重新启动容器，这样外部程序就可以访问kafka了

springboot 配置：

\#kafka  
\# 指定kafka 代理地址，可以多个  
spring.kafka.bootstrap-servers=kafka001:9092  
\# 指定listener 容器中的线程数，用于提高并发量  
spring.kafka.listener.concurrency=1  
\# 每次批量发送消息的数量  
spring.kafka.producer.batch-size=1000  
\# 指定默认消费者group id  
spring.kafka.consumer.group-id=myGroup  
\# 指定默认topic id  
spring.kafka.template.default-topic=topic-1  
spring.kafka.consumer.group-id=test-consumer-group

\*\*\*\*\*记得windows也要配hosts

代码参考：[https://github.com/hsn999/start-cloud][https_github.com_hsn999_start-cloud]

[https_github.com_hsn999_start-cloud]: https://github.com/hsn999/start-cloud

发表评论取消回复

表情：

评论列表（有 0 条评论，1人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka各种报错

Kafka各种报错 * 1.Replication factor: 2 larger than available brokers: 1 * 2.ERROR ...

淡淡的烟草味﹌/ 2024年04月18日 10:33/ 0 赞/ 91 阅读

相关 java 连接 docker kafka环境报错

编辑 docker-compose.yml ，要使外网能访问docker内部的kafka， KAFKA\_ADVERTISED\_LISTENERS: PLAINTEXT:/

ゝ一纸荒年。/ 2023年06月08日 10:58/ 0 赞/ 2 阅读

相关 flink连接kafka函数getAllPartitionsForTopics报错NullPointerException

具体报错如下 java.lang.NullPointerException at org.apache.flink.streaming.connectors

谁借莪１个温暖的怀抱￠/ 2023年01月17日 13:51/ 0 赞/ 199 阅读

相关 Navicat连接docker中的mysql报错

![在这里插入图片描述][20190112141743111.jpg] 解决办法： 1、首先docker ps命令查看正在运行的容器，确保我们想要连接的mysql已经启

叁歲伎倆/ 2022年03月27日 06:26/ 0 赞/ 410 阅读

相关 kafka-java客户端连接报错解决方案

> 背景第一次使用kafka，对他还不是很熟悉。然后在使用java发送消息的时候，一直报错，报错信息如下： Can't resolve address hos

﹏ヽ暗。殇╰゛Y/ 2022年02月20日 10:57/ 0 赞/ 843 阅读

相关 Docker启动报错

time="2015-02-10T15:26:08+08:00" level="info" msg="+job serveapi(unix:///var/run/docker.

分手后的思念是犯贱/ 2022年02月05日 00:37/ 0 赞/ 348 阅读

相关 mysql连接数据库,navicat报错2059,docker镜像

原因报错:“Authentication plugin ‘caching\_sha2\_password’ cannot be loaded” 百度来的原因,时间是

叁歲伎倆/ 2021年12月14日 01:45/ 0 赞/ 359 阅读

相关 Docker报错处理

报错exec: “docker-proxy”: executable file not found in $PATH ln -s /usr/libexec/doc

骑猪看日落/ 2021年12月03日 04:39/ 0 赞/ 463 阅读

相关启动kafka报错

执行启动kafka服务的命令时报错：nohup bin/kafka-server-start.sh config/server.properties 2>&1 & \[201

川长思鸟来/ 2021年11月17日 05:08/ 0 赞/ 518 阅读

相关 Navicat 连接docker mysql报错

![395729-20190625145344161-2131160451.png][] 解决办法： docker exec -it dc10e8b328d7 bas

川长思鸟来/ 2021年10月18日 07:56/ 0 赞/ 478 阅读