Я запускаю kafka в качестве контейнера, вот часть сочинения файла < /p>
kafka:
image: bitnami/kafka:latest
container_name: kafka
restart: always
deploy:
resources:
limits:
memory: 1024M
ports:
- '9092:9092'
volumes:
- "kafka_data_storage:/bitnami"
environment:
KAFKA_CFG_NODE_ID: 0
KAFKA_CFG_PROCESS_ROLES: controller,broker
ALLOW_PLAINTEXT_LISTENER: "yes"
KAFKA_CFG_LISTENERS: INTERNAL://:19092,CONTROLLER://:9093,EXTERNAL://:9092
KAFKA_CFG_ADVERTISED_LISTENERS: INTERNAL://kafka:19092,EXTERNAL://localhost:9092
KAFKA_CFG_INTER_BROKER_LISTENER_NAME: INTERNAL
KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT
KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false"
KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: 0@kafka:9093
KAFKA_CFG_CONTROLLER_LISTENER_NAMES: CONTROLLER
healthcheck:
test: [ "CMD", "kafka-topics.sh", "--list", "--bootstrap-server", "localhost:9092" ]
interval: 10s
timeout: 10s
retries: 5
< /code>
У меня есть служба Java с использованием Spring Kafka, которая потребляет одну из темы в этом кластере, и я подтвердил, что тема присутствует, когда я запускаю услугу. Вот Service Application.yaml Config для kafka: < /p>
kafka:
bootstrap-servers:
- localhost:9092
producer:
client-id: some-client-id
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
consumer:
group-id: some-client-id
auto-offset-reset: earliest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
< /code>
Раньше работал, как и ожидалось, и я видел этот журнал в самом конце запуска: < /p>
INFO 1 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : some-client-id: partitions assigned: [some-topic-0]
< /code>
Но за последние два дня он действует, и я вижу следующее журнал в конце запуска, и он продолжает повторять: < /p>
INFO 45520 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-some-client-1, groupId=some-client] Disconnecting from node -1 due to request timeout.
INFO 45520 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-some-client-1, groupId=some-client] Cancelled in-flight API_VERSIONS request with correlation id 8 due to node -1 being disconnected (elapsed time since creation: 32563ms, elapsed time since send: 32563ms, request timeout: 30000ms)
WARN 45520 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-some-client-1, groupId=some-client] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
< /code>
Это полностью заблокировало мою работу, есть и другие услуги, которые не могут подключиться к Кафке. Я пробовал: < /p>
Очистка и запуск Compose < /li>
Удаление изображений и вытягиваю их обратно и начинает сочинять < /li>
Понижение версии kafka < /li>
перезапустить ПК < /li>
< /ul>
Нет не сработал.
Когда я запускаю какой -либо сервис в качестве контейнера в том же композите, он может подключаться к Кафке, но локально это не так. -1?
Подробнее здесь: https://stackoverflow.com/questions/794 ... un-locally
