product-consumer修改了配置文件，但是kafka还是连接了127.0.0.1

Question

{“level”:“warn”,“ts”:1673924903.9109278,“caller”:“logger@v0.0.0-20220717100747-3cf477b9a8d7/logger.go:219”,“msg”:"kafka consumer Rebalanced ",“produc
t-consumer”:{“Type”:3,“Claimed”:null,“Released”:null,“Current”:{}}}
{“level”:“error”,“ts”:1673924903.9109278,“caller”:“logger@v0.0.0-20220717100747-3cf477b9a8d7/logger.go:223”,“msg”:"kafka consumer msg error ",“error”
:“dial tcp 127.0.0.1:9092: connectex: No connection could be made because the target machine actively refused it.”,“stacktrace”:“gitee.com/phper95/pk
g/logger.Error\n\tD:/projects/go_code/pkg/mod/gitee.com/phper95/pkg/logger@v0.0.0-20220717100747-3cf477b9a8d7/logger.go:223\ngitee.com/phper95/pkg/mq
.(*Consumer).consumerMessage\n\tD:/projects/go_code/pkg/mod/gitee.com/phper95/pkg/mq@v0.0.0-20220717100747-3cf477b9a8d7/kafka_consumer.go:183”}
{“level”:“warn”,“ts”:1673924904.1926696,“caller”:“logger@v0.0.0-20220717100747-3cf477b9a8d7/logger.go:219”,“msg”:“kafka consumer receive system signa
linterrupt”}

然后我在product-consumer.go 直接写ip也是 不行，启动都是连接127.0.0.1:9092的
这是什么原因呢

Answer 1

提问者 蜗牛没有窝 2023-01-17 11:35:41

docker-compose.yml  的配置问题导致的

 

version: '3'

services:

  zookeeper:

    image: wurstmeister/zookeeper

    ports:

      - "2181:2181"

    restart: always

  kafka:

    image: wurstmeister/kafka

    depends_on: [ zookeeper ]

    ports:

      - "9092:9092"

    environment:

      KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1

      KAFKA_CREATE_TOPICS: "shop-order:1:1"

      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

    restart: always