Приложение на java не видит сервер Kafka запущенный в докере на другом хосте

Разбираюсь с Kafka на предмет использования в приложении на java. Запустил kafka в виртуальной машине пол Linux. Запускаю брокер с настройками

broker.id=0
listeners=PLAINTEXT://0.0.0.0:9095
advertised.listeners=PLAINTEXT://10.121.15.8:9095

Запускаю java-приложение на другой машине. Все работает - пишет и читает сообщения. Вопрос: с какими настройками надо запустить kafka в докере на моей виртуалке, чтобы можно было с ней работать с другой машины.

Но если запускаю приложение на другой машине, то оно не видит сервер Запускаю docker-compose c такими настройками

version: '2'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:6.1.1
    hostname: zookeeper
    container_name: zookeeper
    ports:
      - "2181:2181"
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000
  broker1:
    image: confluentinc/cp-kafka:6.1.1
    hostname: broker1
    container_name: broker1
    depends_on:
      - zookeeper
    ports:
      - "29095:29095"
      - "9095:9095"
    environment:
      KAFKA_BROKER_ID: 0
      KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:29095,PLAINTEXT_HOST://10.121.15.8:9095 

И приложение на java не видит сервер

org.apache.kafka.common.errors.NotCoordinatorException: This is not the correct coordinator.
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] (Re-)joining group
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] Group coordinator 10.121.15.8:9095 (id: 2147483647 rack: null) is unavailable or invalid due to cause: error response NOT_COORDINATOR.isDisconnected: false. Rediscovery will be attempted.
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] JoinGroup failed: This is not the correct coordinator. Marking coordinator unknown. Sent generation was Generation{generationId=-1, memberId='', protocol='null'}
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] Discovered group coordinator 10.121.15.8:9095 (id: 2147483647 rack: null)
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] Group coordinator 10.121.15.8:9095 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: false. Rediscovery will be attempted.
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] Discovered group coordinator 10.121.15.8:9095 (id: 2147483647 rack: null)
[main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-my_kafka_hello-1, groupId=my_kafka_hello] Rebalance failed.

Ответы (0 шт):