Bulk Operation

KAFKA-8410 Convert KTable suppress to new PAPI

KAFKA-8410 After processors, migrate TupleForwarder and CacheFlushListener

KAFKA-8410 After migrating processors, search the codebase for missed migrations

KAFKA-8410 KIP-478: deprecate the replaced Processor API members

KAFKA-8410 KIP-478: Delegate the store wrappers to the new init method

KAFKA-8410 KIP-478: Deprecate the old PAPI interfaces

KAFKA-8410 Convert KTable aggregations to new PAPI

KAFKA-8410 Convert KTable joins to new PAPI

KAFKA-8410 Convert KTable maps to new PAPI

KAFKA-8410 Convert KTable filters to new PAPI

KAFKA-8410 Convert KStream aggregations to new PAPI

KAFKA-8410 Convert KStreamImpl joins to new PAPI

KAFKA-8410 Convert KStreamImpl maps to new PAPI

KAFKA-8410 Convert KStreamImpl filters to new PAPI

KAFKA-8410 KIP-478: Implement KStream changes

KAFKA-8410 KIP-478: Implement StateStoreContext and Record

KAFKA-8410 KIP-478: Implement test-utils changes

KAFKA-8410 Implement KIP-478 Topology changes

KAFKA-8410 Implement the KIP-478 StreamBuilder#addGlobalStore()

KAFKA-8410 Introduce the KIP-478 processors with shims