diff --git a/server/modules/protocol/examples/cdc_kafka_producer.py b/server/modules/protocol/examples/cdc_kafka_producer.py
index 1d9a664db..5e09f0734 100755
--- a/server/modules/protocol/examples/cdc_kafka_producer.py
+++ b/server/modules/protocol/examples/cdc_kafka_producer.py
@@ -36,7 +36,7 @@ producer = KafkaProducer(bootstrap_servers=[opts.kafka_broker])
 
 while True:
    try:
-      buf = sys.stdin.read(128)
+      buf = sys.stdin.readline()
 
       if len(buf) == 0:
          break