[
https://issues.apache.org/jira/browse/NIFI-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard resolved NIFI-15285.
-----------------------------------
Resolution: Duplicate
> 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
> Priority: Major
>
> 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)
