product-consumer修改了配置文件，但是kafka还是连接了127.0.0.1
来源：7-17 索引商品数据 (三)
蜗牛没有窝
2023-01-17
{“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的
这是什么原因呢
1回答
-
蜗牛没有窝
提问者
2023-01-17
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
10