data-prepper
data-prepper copied to clipboard
Duplicated buffer logic in PeerForwarderReceiveBuffer which is similar to BlockingBuffer
Is your feature request related to a problem? Please describe.
Data Prepper currently has a BlockingBuffer
plugin which is used a buffer. Core Peer Forwarding(#700) requires a similar buffer for PeerForwarderServer
but with some minor changes which is being added as part of #1641. With two buffers exactly similar, there's a lot of duplicate code.
Describe the solution you'd like
Buffer logic implemented only once which can be used by both BlockingBuffer
and PeerForwarderReceiveBuffer
.