Protocol-Level Kafka Controls in a Customizable Proxy

This research introduces a customizable proxy to enhance the security and governance of Apache Kafka. The proxy uses TransformNode, DecisionNode, and ObserverNode controls to manage data flows without modifying existing client applications. Initial tests show negligible latency impact, validating its effectiveness in improving Kafka’s security and governance capabilities while maintaining system efficiency.