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