Как установить динамические свойства на процессоре PublishKafka_2_0 в Apache NiFi

Question

Я использую процессор PublishKafka_2_0 и мне нужно отключить алгоритм идентификации конечной точки SSL при подключении к Kafka. Из docs я могу сделать это, установив в качестве значения свойства следующего производителя пустую строку:

ssl.endpoint.identification.algorithm=

В документации PublishKafka_2_0 упоминается, что это можно установить с помощью динамических свойств. Может кто-нибудь показать, как установить это свойство? Скриншот или ссылка на пример были бы отличными.

Я использую NiFi 1.9.1 и Apache Kafka 2.1.1

Спасибо

Answer 1

Хотя я настоятельно не рекомендую отключать проверку конечных точек, для этого нажмите значок + в правом верхнем углу вкладки свойств процессора, введите значение ssl.endpoint.identification.algorithm для динамическогоимя свойства и установите флажок «Пустая строка» для значения свойства.

Я только бросил быстрый взгляд, но не вижу этого свойства, определенного в классе ProducerConfig в зависимости org.apache.kafka:kafka-clients-2.0.0.jar.Если предопределенная строка отсутствует, вы можете получить ошибку проверки в NiFi «Должен быть известный параметр конфигурации для этого клиента kafka».