kruscho opened a new issue, #4533: URL: https://github.com/apache/streampipes/issues/4533
### Apache StreamPipes version dev (current development state) ### Affected StreamPipes components UI ### What happened? Currently, the configuration of the KafkaSink appears to assume a single Kafka server endpoint. However, in a typical Apache Kafka setup, clients are expected to connect to a cluster of brokers rather than a single node. Kafka clients (including producers used in sinks) usually rely on the concept of bootstrap servers. This means that multiple broker endpoints can (and should) be provided during initialization to ensure: - High availability - Failover in case a broker is unavailable - Better resiliency in distributed environments ### How to reproduce? _No response_ ### Expected behavior The KafkaSink configuration should allow specifying multiple Kafka brokers as bootstrap servers, for example: bootstrap.servers=broker1:9092,broker2:9092,broker3:9092 ### Additional technical information **Suggested Improvement** - Allow comma-separated list of bootstrap servers in KafkaSink configuration - Validate and pass the configuration directly to the underlying Kafka producer client **Acceptance Criteria** - KafkaSink accepts multiple brokers as input - Configuration supports standard Kafka bootstrap.servers format - Connection works even if one of the listed brokers is unreachable ### Are you willing to submit a PR? No, I don't want to submit a PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
