# Is there any open-source kafka sink connector plugin for OpenSearch for self-managed cluster?

**URL:** <https://forum.opensearch.org/t/is-there-any-open-source-kafka-sink-connector-plugin-for-opensearch-for-self-managed-cluster/28000>\
**Category:** OpenSearch\
**Created:** [April 21, 2026, 8:15am UTC](https://forum.opensearch.org/t/is-there-any-open-source-kafka-sink-connector-plugin-for-opensearch-for-self-managed-cluster/28000 "2026-04-21T08:15:36Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Alex26](https://avatars.discourse-cdn.com/v4/letter/a/6f9a4e/32.png) [@Alex26](https://forum.opensearch.org/u/Alex26)\
**Post date:** [April 21, 2026, 8:15am UTC](https://forum.opensearch.org/t/is-there-any-open-source-kafka-sink-connector-plugin-for-opensearch-for-self-managed-cluster/28000/1 "2026-04-21T08:15:36Z")

</div>

**Versions** (relevant - OpenSearch/Dashboard/Server OS/Browser):

1.3.x

**Describe the issue** :

My current OpenSearch version is 1.3 and I use the 11.1.5 version of confluent kafka connect plugin in a self-managed cluster to push data from kafka topic to OpenSearch.  
Confluent will not support those connectors for self-managed cluster, and the latest versions of that plugin are no longer to be supported to OpenSearch. ref: [Migrating from the Elasticsearch Sink Connector to the HTTP Sink Connector for OpenSearch – Confluent Support Portal](https://support.confluent.io/hc/en-us/articles/39451372312596-Migrating-from-the-Elasticsearch-Sink-Connector-to-the-HTTP-Sink-Connector-for-OpenSearch)

After searching around, only find this project [GitHub - Aiven-Open/opensearch-connector-for-apache-kafka: Aiven's OpenSearch® Connector for Apache Kafka® · GitHub](https://github.com/Aiven-Open/opensearch-connector-for-apache-kafka) , but seems outdated and not active, since the latest release is from Aug 2023.

Do you know any open-source sink connectors for OpenSearch, currently active to use on self-managed cluster?

---

<div class="post-metadata">

**Author:** ![Anthony](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.opensearch.org/anthony/32/9939_2.png) [@Anthony](https://forum.opensearch.org/u/Anthony)\
**Post date:** [April 21, 2026, 9:06am UTC](https://forum.opensearch.org/t/is-there-any-open-source-kafka-sink-connector-plugin-for-opensearch-for-self-managed-cluster/28000/2 "2026-04-21T09:06:43Z")

</div>

@Alex26 Welcome to the forum and thank you for the question.

Have you had a look at [Data Prepper](https://docs.opensearch.org/latest/data-prepper/)? In [version 2.4](https://opensearch.org/blog/Announcing-Data-Prepper-2.4.0/) Kafka was added as one of the sources.

You might also find [this blog](https://franco-martin.medium.com/setting-up-data-prepper-for-opensearch-and-opentelemetry-e701897811a2) useful.

Hope this helps