[GitHub] [pulsar] yuvalgut opened a new issue #9990: Add write(Collection records) to pulsar io sink interface

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org

[GitHub] [pulsar] codelipenghui commented on issue #9990: Add write(Collection records) to pulsar io sink interface

[GitBox <gi...@apache.org>]

codelipenghui commented on issue #9990:
URL: https://github.com/apache/pulsar/issues/9990#issuecomment-1058892198


   The issue had no activity for 30 days, mark with Stale label.


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org