Приложение на 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.