diff --git a/groot-stream/templates/datapath_telemetry_record.yaml.j2 b/groot-stream/templates/datapath_telemetry_record.yaml.j2
index 2bbd68e..0616617 100644
--- a/groot-stream/templates/datapath_telemetry_record.yaml.j2
+++ b/groot-stream/templates/datapath_telemetry_record.yaml.j2
@@ -38,6 +38,7 @@ sinks:
     type: kafka
     properties:
       topic: {{ kafka_sink_topic }}
+      kafka.client.id: {{ kafka_sink_topic }}
       kafka.bootstrap.servers: {{ kafka_sink_servers }}
       kafka.retries: 0
       kafka.linger.ms: 10