diff --git a/packages/kafka_connect/changelog.yml b/packages/kafka_connect/changelog.yml
index 762f261ec19..e6529513473 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: https://github.com/elastic/integrations/pull/19354
 - 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