yuvalgut opened a new issue #9990: URL: https://github.com/apache/pulsar/issues/9990
I see that a lot of pulsar sinks tries to implement some sort of accumulation/batching behavior on pulsar sink, which makes sense because a lot of targets prefer handling a batch of data. this code is just a duplication of what pulsar already offers for consumer, the 'batchReceive' method. **Describe the solution you'd like** add another method signature void write(Collection<T> records) to the sink interface. this is also the 'write' interface kafka connect exposes allow specifying 'batch' behavior for the consumer. **Describe alternatives you've considered** implement batching on every sink -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
