в строку запуска кафки как-то можно передать параметр где хранить логи ?

или переменные окружения может оно подхватывает

Ребята, подскажите пожалуйста в consumer.properties как указать корректно передачу логина пароля в sasl

пробую в таком виде:

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="test-user" password="test-user";

не принимает

Ковычки

спасибо большое

Подскажите, может кто-то сталкивался

- Java 11
- kafka-clients 2.3.0/2.4.0 отлично коннектится к брокеру в докер контейнере и работает как нужно

- при апдейте клиента на 2.4.1/2.5.x/2.6.0 насыпает в WARN следующее:
o.a.kafka.clients.NetworkClient:1024 - [Producer clientId=producer-1] Bootstrap broker 127.0.0.1:9092 (id: -1 rack: null) disconnected

конфигурация продюсеров/консьюмеров само собой не меняется
в докере брокер на версии 2.4.1/2.5.1/2.6.0 - роли не играет

примитивный конфиг компоуза (чисто для интеграционных тестов, месяцами работает без единого сбоя)
https://pastebin.com/RnHF93VY

по конфигу продюсеров/консьюмеров тоже все примитивно
- bootstrap.servers=127.0.0.1:9092
- key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
- value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
- group.id=some_sink
- auto.offset.reset=earliest
- enable.auto.commit=false
остальное все на дефолтах

релиз ноуты 2.4.1 прошерстил, ничего особеного не заметил
гуглом основательно прошелся, но все на тему ssl/etc, а у меня в даном случае PLAINTEXT все коммуникации

вообщем переехал на
- confluentinc/cp-zookeeper:latest
- confluentinc/cp-kafka:latest
и все заработало

Ну latest это всегда bold move 😅

само собой так не останется, но сейчас для тестов сойдет 🙂

Коллеги, кто разбирается, подскажите, пожалуйста: возможно ли использовать комьюнити-версию Confluent Schema Registry с бесплатной кафкой, или этот инструмент работает только вместе с платной Confluent Platform?
Быстрое гугление не помогло найти ответ на этот вопрос.

Да возможно. А чего не взять бесплатную кафку от Confluent?

Так а где её взять? Я видел только версию которая будет активна 30 дней а дальше вообще не понятно что случится)

Не, есть же community версия где все синтегрировано

Идёшь https://www.confluent.io/download в низу есть кнопка Community features - это бесплатно и там есть SR.
Сорян что так витеевато, growth hackers не дают нормально адвокатам работать - все время придумывают всякие хитрости

Я взял вот тут
https://docs.confluent.io/current/installation/installing_cp/zip-tar.html

Специально выбрал "Confluent Platform using only Confluent Community components", то есть файл

http://packages.confluent.io/archive/6.0/confluent-community-6.0.0.zip

Там есть schema registry, запускается и ничего не говорит про 30 дней

Все правильно сделал