Dariusz Seweryn created NIFI-15285:
--------------------------------------
Summary: Make Kafka3ConnectionService verify Broker Connections
Key: NIFI-15285
URL: https://issues.apache.org/jira/browse/NIFI-15285
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Affects Versions: 2.6.0
Reporter: Dariusz Seweryn
Assignee: Dariusz Seweryn
ConsumeKafka and PublishKafka processors can work when they can connect to
Kafka Brokers.
h3. Current State
Kafka3ConnectionService, ConsumeKafka and ProduceKafka do verify the connection
to the bootstrap server by listing topics. This does not provide information
whether all Broker Nodes can be connected to.
h3. Improvement
In Kafka3ConnectionService verify if all nodes can be reached. This requires
cluster description call and calls for each individual node to describe config.
In case the user does not have authorization to describe the cluster, the code
could fallback to open a socket connection to listed bootstrap servers.
In case there are many nodes, the describe config call can be run in parallel
using virtual threads.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
