From c223d11fd503fb62854d5b199abfa60a4f21622c Mon Sep 17 00:00:00 2001 From: Akash Sivakumar Date: Thu, 14 Nov 2024 17:13:29 -0700 Subject: [PATCH] remove intermdiate json --- preprocessing/pcap_processor.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/preprocessing/pcap_processor.py b/preprocessing/pcap_processor.py index 8905352..21a9e6f 100644 --- a/preprocessing/pcap_processor.py +++ b/preprocessing/pcap_processor.py @@ -18,7 +18,8 @@ KAFKA_SERVER = 'localhost:9092' # Adjust to your Kafka server # Initialize Kafka Producer producer = KafkaProducer( bootstrap_servers=KAFKA_SERVER, - value_serializer=lambda v: json.dumps(v).encode('utf-8') # Encode data as JSON + #value_serializer=lambda v: json.dumps(v).encode('utf-8') # Encode data as JSON + value_serializer=lambda v: v.encode('utf-8') if isinstance(v, str) else str(v).encode('utf-8') #remove intermediate JSON encoding )