MXS-1316: Read the raw input in cdc_kafka_producer.py
The input can be read as raw bytes since kafka expects the data to be of type bytes instead of str.
This commit is contained in:
@ -30,6 +30,7 @@ parser.add_argument("-T", "--kafka-topic", dest="kafka_topic",
|
|||||||
|
|
||||||
opts = parser.parse_args(sys.argv[1:])
|
opts = parser.parse_args(sys.argv[1:])
|
||||||
producer = KafkaProducer(bootstrap_servers=[opts.kafka_broker])
|
producer = KafkaProducer(bootstrap_servers=[opts.kafka_broker])
|
||||||
|
sys.stdin = sys.stdin.detach()
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
|
Reference in New Issue
Block a user