This is a sample project demonstrating how to build a Python extension that can be executed together with its dependencies. The project is modeled after the Apache NiFi Python developer guide for ...
The application runs 14 Broadway pipeline workers, each consuming a specific Zeek log type from Kafka (e.g., conn, dns, http, ssl). Messages are decoded from JSON, fields are extracted and coerced to ...