From e65cf00d34cc721347e271f9d85bc1675c8a63e9 Mon Sep 17 00:00:00 2001 From: Akash Sivakumar Date: Wed, 20 Nov 2024 20:10:15 -0700 Subject: [PATCH] branch test commit --- preprocessing/pcap_processor.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/preprocessing/pcap_processor.py b/preprocessing/pcap_processor.py index 09c556a..99aaa09 100644 --- a/preprocessing/pcap_processor.py +++ b/preprocessing/pcap_processor.py @@ -11,6 +11,8 @@ import json dbg_print = lambda *x: DEBUG and print(f"[DEBUG] {x}") + + class KafkaClient: def __init__(self, topic_name=None, mode='producer'): self.mode = mode