Неожиданный запрос Kafka типа METADATA во время установления связи SASL ⇐ JAVA

[Anonymous]

Я пытаюсь подключить Java-клиент Kafka к брокеру Kafka с помощью SASL Plain. Но когда я пытаюсь отправить сообщение от производителя, сервер Kafka регистрирует следующую ошибку:

Код: Выделить всё

[2020-04-30 14:48:14,955] INFO [SocketServer brokerId=0] Failed authentication with /127.0.0.1 (Unexpected Kafka request of type METADATA during SASL handshake.) (org.apache.kafka.common.network.Selector)

Судя по всему, производитель пытается отправить запрос метаданных до подтверждения SASL. Как мне выполнить рукопожатие перед отправкой сообщения?

Ниже приведен мой файл kafka_server_jaas.conf, который используется для сервера Kafka.

Код: Выделить всё

KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret";
};

Client {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret";
};

Ниже приведен мой файл Zookeeper_jaas.conf, который используется для Zookeeper:

Код: Выделить всё

Server {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret";
};

В моем продукте Java я установил следующие свойства:

Код: Выделить всё

Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"admin\" password=\"admin_secret\"");
properties.put("sasl.mechanisms", "PLAIN");
properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
KafkaProducer kafkaProducer = new KafkaProducer(properties);

Я делаю что-то не так?


Подробнее здесь: https://stackoverflow.com/questions/615 ... -handshake