[jira] [Resolved] (CAMEL-16071) Support custom Kafka client instances

["Claus Ibsen (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CAMEL-16071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Claus Ibsen resolved CAMEL-16071.
---------------------------------
    Fix Version/s:     (was: 3.x)
                   3.8.0
       Resolution: Fixed

Thanks for the PRs

> Support custom Kafka client instances
> -------------------------------------
>
>                 Key: CAMEL-16071
>                 URL: https://issues.apache.org/jira/browse/CAMEL-16071
>             Project: Camel
>          Issue Type: Improvement
>          Components: camel-kafka
>            Reporter: Javier Holguera
>            Priority: Major
>             Fix For: 3.8.0
>
>
> The camel-kafka component instantiates Kafka client instances (e.g., KafkaConsumer and KafkaProducer) directly. This prevents users to leverage their own custom implementations for them. Kafka Streams library solved this issue a long time ago (see https://issues.apache.org/jira/browse/KAFKA-3616) adding the ability to pass a factory of Kafka clients to the Streams processor.
> Steps for implementation:
>  # Add a new `KafkaClientFactory` interface with methods to get instances of Kafka's `KafkaConsumer` and `KafkaProducer`.
>  # Add a default implementation `DefaultKafkaClientFactory` that instantiates both as they are at the moment inside the Camel's `KafkaConsumer` and `KafkaProducer` (simply calling `new` with a `Properties` object).
>  # Add a new 'KafkaClientFactory' configuration option that defaults to `DefaultKafkaClientFactory`.
>  # Use this factory inside Camel's `KafkaConsumer` and `KafkaProducer` (instead of doing a `new` directly).



--
This message was sent by Atlassian Jira
(v8.3.4#803005)