Criei este seguinte docker-compose para subir os serviços do zookeeper e do kafka
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:7.3.5
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
ports:
- 22181:2181
kafka:
image: confluentinc/cp-kafka:7.3.5
depends_on:
- zookeeper
ports:
- 29092:29092
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
O serviço e startado sem erros
Name Command State Ports
--------------------------------------------------------------------------------------------------------------------------
ecommerce_kafka_1 /etc/confluent/docker/run Up 0.0.0.0:29092->29092/tcp,:::29092->29092/tcp, 9092/tcp
ecommerce_zookeeper_1 /etc/confluent/docker/run Up 0.0.0.0:22181->2181/tcp,:::22181->2181/tcp, 2888/tcp, 3888/tcp
Quando executo o cliente tenho o seguinte erro
[main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=FraudeDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available.
[main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=FraudeDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available.
O mesmo acontece com o Produtor
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.3.1
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 18a913733fb71c01
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1696506533062
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available.
Como posso resolver este erro?
