Невозможно подключиться к Кафке, попав в продюсер, в докере-композитеJAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 Невозможно подключиться к Кафке, попав в продюсер, в докере-композите

Сообщение Anonymous »

Это мой docker-compose.yml < /p>
version: '3.8'

services:
parking_service:
build:
context: .
ports:
- "8081:8081"
depends_on:
postgres:
condition: service_healthy
kafka:
condition: service_healthy
environment:
- DB_HOST=postgres
- SPRING_DATASOURCE_URL=jdbc:postgresql://postgres:5432/car_parking
- SPRING_DATASOURCE_USERNAME=myuser
- SPRING_DATASOURCE_PASSWORD=mypassword
- SPRING_KAFKA_BOOTSTRAP_SERVERS=kafka:9092
networks:
- parking_network

postgres:
image: postgres:13
environment:
POSTGRES_USER: myuser
POSTGRES_PASSWORD: mypassword
POSTGRES_DB: car_parking
volumes:
- postgres-data:/var/lib/postgresql/data
ports:
- "5433:5432"
healthcheck:
test: ["CMD-SHELL", "pg_isready -U myuser -d car_parking"]
interval: 5s
timeout: 5s
retries: 10
networks:
- parking_network

zookeeper:
image: wurstmeister/zookeeper:latest
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
networks:
- parking_network

kafka:
image: wurstmeister/kafka:latest
environment:
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

ports:
- "9092:9092"
healthcheck:
test: [ "CMD", "kafka-topics.sh", "--list", "--bootstrap-server", "kafka:9092" ]
interval: 20s
timeout: 10s
retries: 15
depends_on:
- zookeeper
networks:
- parking_network

volumes:
postgres-data:

networks:
parking_network:
driver: bridge
< /code>
Итак, когда я делаю Docker-Compose Up-Build и нажимаю API, я вижу эту ошибку, вставленную ниже < /p>
**enter code hereparking_service-1 | 2025-04-23T10:43:36.357Z INFO 1 --- [parking_service] [vice-producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=parking_service-producer-1] Node -1 disconnected.
parking_service-1 | 2025-04-23T10:43:36.359Z WARN 1 --- [parking_service] [vice-producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=parking_service-producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available.
parking_service-1 | 2025-04-23T10:43:36.360Z WARN 1 --- [parking_service] [vice-producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=parking_service-producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
parking_service-1 | 2025-04-23T10:43:37.266Z INFO 1 --- [parking_service] [vice-producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=parking_service-producer-1] Node -1 disconnected.
parking_service-1 | 2025-04-23T10:43:37.266Z WARN 1 --- [parking_service] [vice-producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=parking_service-producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available.
parking_service-1 | 2025-04-23T10:43:37.266Z WARN 1 --- [parking_service] [vice-producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=parking_service-producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
parking_service-1 | 2025-04-23T10:43:37.403Z ERROR 1 --- [parking_service] [nio-8081-exec-2] o.s.k.support.LoggingProducerListener : Exception thrown when sending a message with key='null' and payload='User 4 parked at slot A3' to topic parking.slot.occupied:
parking_service-1 |
parking_service-1 | org.apache.kafka.common.errors.TimeoutException: Topic parking.slot.occupied not present in metadata after 60000 ms.
parking_service-1 |
parking_service-1 | 2025-04-23T10:43:37.431Z DEBUG 1 --- [parking_service] [nio-8081-exec-2] o.s.web.servlet.DispatcherServlet : Failed to complete request: org.springframework.kafka.KafkaException: Send failed**


Подробнее здесь: https://stackoverflow.com/questions/795 ... er-compose
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение
  • Как соскрести PDF -файлы из списка веб -сайтов и субдоменов, не попав в CAPTCHA? (R, Python)
    Anonymous » » в форуме Python
    0 Ответы
    9 Просмотры
    Последнее сообщение Anonymous
  • Как реализовать многопоточный продюсер Kafka на Java
    Anonymous » » в форуме JAVA
    0 Ответы
    8 Просмотры
    Последнее сообщение Anonymous
  • Как реализовать многопоточный продюсер Kafka на Java
    Anonymous » » в форуме JAVA
    0 Ответы
    8 Просмотры
    Последнее сообщение Anonymous
  • Создайте музыку, воспроизводимую анимацию на композите
    Anonymous » » в форуме Android
    0 Ответы
    14 Просмотры
    Последнее сообщение Anonymous
  • Создайте музыку, воспроизводимую анимацию на композите
    Anonymous » » в форуме Android
    0 Ответы
    7 Просмотры
    Последнее сообщение Anonymous

Вернуться в «JAVA»