From d9137d28f7755f0ede27c104e05fb2a2e8035621 Mon Sep 17 00:00:00 2001
From: Alphayeeeet <52979715+Alphayeeeet@users.noreply.github.com>
Date: Wed, 3 Jun 2026 11:46:37 +0200
Subject: [PATCH 1/2] Add condition field to Kafka Connect integration for
 condition based autodiscovery

---
 packages/kafka_connect/changelog.yml                     | 5 +++++
 .../data_stream/client/agent/stream/stream.yml.hbs       | 3 +++
 .../data_stream/connector/agent/stream/stream.yml.hbs    | 3 +++
 .../data_stream/task/agent/stream/stream.yml.hbs         | 3 +++
 .../data_stream/worker/agent/stream/stream.yml.hbs       | 3 +++
 packages/kafka_connect/manifest.yml                      | 9 ++++++++-
 6 files changed, 25 insertions(+), 1 deletion(-)

diff --git a/packages/kafka_connect/changelog.yml b/packages/kafka_connect/changelog.yml
index 762f261ec19..d291099ee9e 100644
--- a/packages/kafka_connect/changelog.yml
+++ b/packages/kafka_connect/changelog.yml
@@ -1,3 +1,8 @@
+- version: "0.2.0"
+  changes:
+    - description: Allow for setting condition
+      type: enhancement
+      link: TODO
 - version: "0.1.0"
   changes:
     - description: Initial release of Kafka Connect integration
diff --git a/packages/kafka_connect/data_stream/client/agent/stream/stream.yml.hbs b/packages/kafka_connect/data_stream/client/agent/stream/stream.yml.hbs
index e1abd82f458..0c7c13c2916 100644
--- a/packages/kafka_connect/data_stream/client/agent/stream/stream.yml.hbs
+++ b/packages/kafka_connect/data_stream/client/agent/stream/stream.yml.hbs
@@ -11,6 +11,9 @@ username: {{username}}
 {{#if password}}
 password: {{password}}
 {{/if}}
+{{#if condition }}
+condition: {{ condition }}
+{{/if}}
 namespace: "kafka_connect"
 jmx.mappings:
   - mbean: 'kafka.connect:type=connect-metrics,client-id=*'
diff --git a/packages/kafka_connect/data_stream/connector/agent/stream/stream.yml.hbs b/packages/kafka_connect/data_stream/connector/agent/stream/stream.yml.hbs
index f5673802ff2..57b97e9db20 100644
--- a/packages/kafka_connect/data_stream/connector/agent/stream/stream.yml.hbs
+++ b/packages/kafka_connect/data_stream/connector/agent/stream/stream.yml.hbs
@@ -11,6 +11,9 @@ username: {{username}}
 {{#if password}}
 password: {{password}}
 {{/if}}
+{{#if condition }}
+condition: {{ condition }}
+{{/if}}
 namespace: "kafka_connect"
 jmx.mappings:
   - mbean: 'kafka.connect:type=connector-metrics,connector=*'
diff --git a/packages/kafka_connect/data_stream/task/agent/stream/stream.yml.hbs b/packages/kafka_connect/data_stream/task/agent/stream/stream.yml.hbs
index d65809d050a..30cd7ddae4e 100644
--- a/packages/kafka_connect/data_stream/task/agent/stream/stream.yml.hbs
+++ b/packages/kafka_connect/data_stream/task/agent/stream/stream.yml.hbs
@@ -11,6 +11,9 @@ username: {{username}}
 {{#if password}}
 password: {{password}}
 {{/if}}
+{{#if condition }}
+condition: {{ condition }}
+{{/if}}
 namespace: "kafka_connect"
 jmx.mappings:
   - mbean: 'kafka.connect:type=*-task-metrics,connector=*,task=*'
diff --git a/packages/kafka_connect/data_stream/worker/agent/stream/stream.yml.hbs b/packages/kafka_connect/data_stream/worker/agent/stream/stream.yml.hbs
index b6e836bf45b..bd2026b390a 100644
--- a/packages/kafka_connect/data_stream/worker/agent/stream/stream.yml.hbs
+++ b/packages/kafka_connect/data_stream/worker/agent/stream/stream.yml.hbs
@@ -11,6 +11,9 @@ username: {{username}}
 {{#if password}}
 password: {{password}}
 {{/if}}
+{{#if condition }}
+condition: {{ condition }}
+{{/if}}
 namespace: "kafka_connect"
 jmx.mappings:
   - mbean: 'kafka.connect:type=connect-worker-metrics'
diff --git a/packages/kafka_connect/manifest.yml b/packages/kafka_connect/manifest.yml
index 69a9e3dd903..827a8890d59 100644
--- a/packages/kafka_connect/manifest.yml
+++ b/packages/kafka_connect/manifest.yml
@@ -1,6 +1,6 @@
 name: kafka_connect
 title: Kafka Connect
-version: "0.1.0"
+version: "0.2.0"
 description: Collect metrics from Kafka Connect instances with Elastic Agent.
 type: integration
 icons:
@@ -43,6 +43,13 @@ policy_templates:
             show_user: true
             description: Path of Jolokia endpoint.
             default: /jolokia/
+          - name: condition
+            title: Condition
+            description: Condition to filter when to collect this input. See [Dynamic Input Configuration](https://www.elastic.co/guide/en/fleet/current/dynamic-input-configuration.html) for details.
+            type: text
+            multi: false
+            required: false
+            show_user: true
           - name: username
             type: text
             title: Username

From 0510ee5f1294bfa691d32eb3ef5eb0b89c7de0e4 Mon Sep 17 00:00:00 2001
From: Alphayeeeet <52979715+Alphayeeeet@users.noreply.github.com>
Date: Wed, 3 Jun 2026 11:48:28 +0200
Subject: [PATCH 2/2] Add PR URL

---
 packages/kafka_connect/changelog.yml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/kafka_connect/changelog.yml b/packages/kafka_connect/changelog.yml
index d291099ee9e..e6529513473 100644
--- a/packages/kafka_connect/changelog.yml
+++ b/packages/kafka_connect/changelog.yml
@@ -2,7 +2,7 @@
   changes:
     - description: Allow for setting condition
       type: enhancement
-      link: TODO
+      link: https://github.com/elastic/integrations/pull/19354
 - version: "0.1.0"
   changes:
     - description: Initial release of Kafka Connect integration