Я пытаюсь настроить клиент kafka для аутентификации на безопасном сервере kafka. Я настроил конфиги jaas и ssl, но он жалуется на имена служб. Я не использую Керберос. команда KAFKA_OPTS="-Djava.security.auth.login.config=./jaas.conf" \...

Когда мы подключаемся к Kafka cluster / kafka, в java-клиентах мы определяем определенные свойства - Пример Свойства производителя Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092");...

Я хочу настроить аутентификацию Kafka (сейчас только аутентификация, шифрование не требуется), используя 2 слушателя: один для межброкерского частного общения с безопасностью PLAINTEXT один для публичного общения потребителей / производителей с...

У меня установлен Strimzi Kafka с кластером Kafka со слушателями TLS (в OpenShift, если это имеет значение). Когда я добавляю KafkaUser , я запрашиваю аутентификацию TLS следующим образом: spec: authentication: type: tls authorization:...