Implement Apache Kafka - KIP-820: Extend KStream process with new Processor API.

Implement Apache Kafka - KIP-820: Extend KStream process with new Processor API.: a task in LoLBench (Harbor dataset). You are working in /workspace/kafka , a source tree checked out at the base commit for this task. Implement the requested behavior in the source tree, then run:

The task

You are working in `/workspace/kafka`, a source tree checked out at the base commit for this task. Implement the requested behavior in the source tree, then run:

Part of lolbench26/LoLBench.