Incomplete - dockerizing kafka streaming

preprocessing/Dockerfile.python

@@ -0,0 +1,20 @@
+# Start with a base image that includes Python
+FROM python:3.9-slim
+
+# Set the working directory inside the container
+WORKDIR /app
+
+# Copy only the requirements.txt file to the container
+COPY requirements.txt /app
+
+# Install the dependencies using the requirements.txt file
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Copy only the pcap_processor.py file to the container
+COPY pcap_processor.py /app
+
+# Expose the port Kafka uses (optional, for communication with other services)
+EXPOSE 9092
+
+# Command to run your Python application
+CMD ["python", "pcap_processor.py"]

preprocessing/pcap_processor.py

@@ -14,6 +14,7 @@ dbg_print = lambda *x: DEBUG and print(f"[DEBUG] {x}")
 # Kafka Configuration
 KAFKA_TOPIC = 'pcap_stream'
 KAFKA_SERVER = 'localhost:9092'  # Adjust to your Kafka server
+#KAFKA_SERVER = 'kafka_service:9092'  
 
 # Initialize Kafka Producer
 producer = KafkaProducer(

preprocessing/requirements.txt

@@ -0,0 +1,2 @@
+kafka-python
+scapy