Измените хост и порт kafka при использовании Quarkus и SmallRye

Я не могу изменить хост и порт Kafka, когда мне нужно запустить его через docker-compose. Я хочу использовать одну и ту же docker-compose для запуска своих сервисов и Kafka. поэтому мне нужно сменить хост Kafka.

Я безуспешно пытался указать следующую переменную среды: mp.messaging.outgoing.my-channel.bootstrap.servers="Kafka:9092"

Я использовал тот же docker-compose в руководствах Quarkus/Kafka:https://quarkus.io/guides/kafka-guide

Источник

2 ответа

Решение

Похоже, что руководство предполагает, что код не работает в контейнере.

Если ваша служба также работает в контейнере, вам необходимо установить это в контейнере Kafka.

KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
Источник

Вот пример файла docker-compose.yaml.

      version: '2'

services:

  zookeeper:
    image: strimzi/kafka:0.20.0-kafka-2.6.0
    command: [
      "sh", "-c",
      "bin/zookeeper-server-start.sh config/zookeeper.properties"
    ]
    ports:
      - "2181:2181"
    environment:
      LOG_DIR: /tmp/logs

  kafka:
    image: strimzi/kafka:0.20.0-kafka-2.6.0 
    command: [
      "sh", "-c",
      "bin/kafka-server-start.sh config/server.properties --override 
listeners=$${KAFKA_LISTENERS} --override 
advertised.listeners=$${KAFKA_ADVERTISED_LISTENERS} --override 
zookeeper.connect=$${KAFKA_ZOOKEEPER_CONNECT}"
    ]
    depends_on:
      - zookeeper
    ports:
      - "9092:9092"
    environment:
      LOG_DIR: "/tmp/logs"
      # Dev GQ - Laptop
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://172.23.240.1:9092
      # AWS Pre-Prod  
      #KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://11.122.200.229:9092
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

А вот пример файла Quarkus application.properties с загрузочным сервером kafka, настроенным как объявленные слушатели в docker-compose.yaml. Это нативная часть другого образа докера.

      # Configure the SmallRye Kafka connector
# Dev GQ - Laptop
mp.messaging.connector.smallrye-kafka.bootstrap.servers=172.23.240.1:9092
# AWS Pre-Prod
#mp.messaging.connector.smallrye-kafka.bootstrap.servers=11.122.200.229:9092
quarkus.kafka.health.enabled=true

# Configure the Kafka sink (we write to it)
mp.messaging.outgoing.generated-price.connector=smallrye-kafka
mp.messaging.outgoing.generated-price.topic=prices
mp.messaging.outgoing.generated-price.value.serializer=org.apache.kafka.common.serialization.IntegerSerializer

# Configure the Kafka source (we read from it)
mp.messaging.incoming.prices.connector=smallrye-kafka
mp.messaging.incoming.prices.topic=prices
# ..... more codes
Источник
Другие вопросы по тегам