# Kafka client from confluent

**URL:** <https://discuss.elastic.co/t/kafka-client-from-confluent/83301>\
**Category:** Beats\
**Tags:** filebeat\
**Created:** [April 23, 2017, 2:31am UTC](https://discuss.elastic.co/t/kafka-client-from-confluent/83301 "2017-04-23T02:31:21Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![lightkz](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/lightkz/32/12386_2.png) [@lightkz](https://discuss.elastic.co/u/lightkz)\
**Post date:** [April 23, 2017, 2:31am UTC](https://discuss.elastic.co/t/kafka-client-from-confluent/83301/1 "2017-04-23T02:31:21Z")

</div>

Is there any plans in roadmap to switch to official Kafka client supported by confluent?

It seems to setup Kafka connect the agent suppose to support “ interceptor.classes”. That is essential feature to setup Kafka connect. We would like to take full advantage on Kafka connect.

> **[confluentinc/confluent-kafka-go](https://github.com/confluentinc/confluent-kafka-go)**
>
> confluent-kafka-go - Confluent's Apache Kafka Golang client

interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor

-Askar

---

<div class="post-metadata">

**Author:** ![steffens](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/steffens/32/79630_2.png) [@steffens](https://discuss.elastic.co/u/steffens)\
**Post date:** [April 24, 2017, 9:28am UTC](https://discuss.elastic.co/t/kafka-client-from-confluent/83301/2 "2017-04-24T09:28:16Z")

</div>

Currently there are no plans for this. Reason is, `confluent-kafka-go` client heavily depends on cgo, but we try to reduce C dependencies as much as possible.

This looks a lot like Java: `interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor`

You sure this works with the C client?

---

<div class="post-metadata">

**Author:** ![lightkz](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/lightkz/32/12386_2.png) [@lightkz](https://discuss.elastic.co/u/lightkz)\
**Post date:** [April 24, 2017, 1:42pm UTC](https://discuss.elastic.co/t/kafka-client-from-confluent/83301/3 "2017-04-24T13:42:24Z")

</div>

That "interceptor" line is from java.

Yeah you might be right I am looking at the client and it might be not implemented there. I am going to follow up with Confluent. I will follow up in a bit on this post.

---

<div class="post-metadata">

**Author:** ![lightkz](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/lightkz/32/12386_2.png) [@lightkz](https://discuss.elastic.co/u/lightkz)\
**Post date:** [April 24, 2017, 3:44pm UTC](https://discuss.elastic.co/t/kafka-client-from-confluent/83301/4 "2017-04-24T15:44:06Z")

</div>

Following up on this. Got response:

> Confluent is in the process of adding in client interceptors that produce stream monitoring metrics to the Confluent Control Center topics. This will be added into all the Confluent client libraries, including the golang client. I am unsure on the exact planned release date.

Thank you Steffen I guess I fired up too fast on this!

-Askar

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [May 22, 2017, 3:56pm UTC](https://discuss.elastic.co/t/kafka-client-from-confluent/83301/5 "2017-05-22T15:56:14Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.