The pull is documented in the code. Its more contextual to read the reasoning there. Mostly the buffer protocol and the flush method. The buffer impl is totally independent of Arroyo/Kafka all the rest. You can write a buffer with no knowledge of where it will be used.
Adds the concept of a Buffer protocol.
Moves all Kafka specific behavior out of the buffer protocol and into the strategy class.
The pull is documented in the code. Its more contextual to read the reasoning there. Mostly the buffer protocol and the flush method. The buffer impl is totally independent of Arroyo/Kafka all the rest. You can write a buffer with no knowledge of where it will be used.