KafkaJS:ECONNREFUSED当试图生成一个主题的消息时

Question

我正在使用KafkaJS生成关于Kafka主题的消息。为此，我使用wurstmeister映像将Kafka服务器放在Docker中。

我想做的是：Poll容器生成一条到Poll主题的消息，并使用来自responsePoll主题的消息。但我在尝试生成消息时出错

错误：poll | {"level":"ERROR","timestamp":"2020-10-24T15:21:27.113Z","logger":"kafkajs","message":"[Connection] Connection error: connect ECONNREFUSED 127.0.0.1:9092","broker":"127.0.0.1:9092","clientId":"BlueOriginX","stack ":"Error: connect ECONNREFUSED 127.0.0.1:9092n at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1145:16)"}

这是docker-compose.yml文件：

version: '3.4'
services:
poll:
container_name: poll
build: ./Services/Poll
ports:
- "4003:4003"
networks:
- blueorigin
zookeeper:
image: wurstmeister/zookeeper:latest
ports:
- "2181:2181"
networks:
- blueorigin
kafka:
image: wurstmeister/kafka:2.11-1.1.1
ports:
- "9092:9092"
links:
- zookeeper
environment:
KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'true'
KAFKA_DELETE_TOPIC_ENABLE: 'true'
KAFKA_CREATE_TOPICS: "Poll:1:1,responsePoll:1:1"
volumes:
- /var/run/docker.sock:/var/run/docker.sock
networks:
- blueorigin
networks:
blueorigin:

我想错误来自我的docker设置，但我不知道：/

编辑：以下是生成消息的代码：

const startPoll = async () =>{
const producer = kafka.producer()
await producer.connect()
await producer.send({
topic: 'Poll',
messages: [
{ value: 'New Poll' },
],
})
await producer.disconnect()
}

Answer 1

我没有你的民意调查应用程序，所以我用Confluent Rest Proxy替换了它，但这个设置有效。我可以在这里看到主题http://localhost:8086/topics。

version: '3.4'
services:
restproxy:
image: confluentinc/cp-kafka-rest:latest
ports:
- "8086:8086"
environment:
KAFKA_REST_HOST_NAME: restproxy
KAFKA_REST_BOOTSTRAP_SERVERS: PLAINTEXT://kafka:9092
KAFKA_REST_LISTENERS: http://0.0.0.0:8086
zookeeper:
image: wurstmeister/zookeeper:latest
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka:2.11-1.1.1
ports:
- "9092:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: kafka
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'true'
KAFKA_DELETE_TOPIC_ENABLE: 'true'
KAFKA_CREATE_TOPICS: "test:1:1"
volumes:
- /var/run/docker.sock:/var/run/docker.sock

你不需要链接和网络，它们是遗留下来的。此外，当您尝试从一个服务连接到另一个服务时，使用localhost也不起作用，这可能就是它不适用于您的原因。