diff --git a/server/modules/protocol/examples/cdc_kafka_producer.py b/server/modules/protocol/examples/cdc_kafka_producer.py
index d8d25d7ed..8197bc2cf 100755
--- a/server/modules/protocol/examples/cdc_kafka_producer.py
+++ b/server/modules/protocol/examples/cdc_kafka_producer.py
@@ -38,7 +38,7 @@ while True:
       if len(buf) == 0:
          break
 
-      data = buf.encode().strip()
+      data = buf[:-1]
       producer.send(topic=opts.kafka_topic, value=data)
       producer.flush()