pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] merlimat commented on issue #3388: [Go Client] - Add ability to send an atomic batch
Date Sat, 19 Jan 2019 02:55:02 GMT
merlimat commented on issue #3388: [Go Client] - Add ability to send an atomic batch
URL: https://github.com/apache/pulsar/issues/3388#issuecomment-455743288
   > Currently the producer batching is a buffer that is flushed according with batching
configs. The problem is that we can loose the messages order, if some fails.
   The ordering will not be lost because the client library will internally resend all the
messages from the failure point. You might see duplicates (unless you enabled deduplication
feature) but you'll not get ordering violation when pipelining multiple outstanding messages.
   > An alternative could be adding a flush method that gives more control to the client,
having the ability to flush the buffer when desired. 
   We already have that method in Java and C++. We just have to expose that in Python and
Go wrapper still.
   Java: http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/Producer.html#flush--
   C++ : http://pulsar.apache.org/api/cpp/classpulsar_1_1_producer.html#a1cd59ffc4a23162eca39183ba4278146

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:

With regards,
Apache Git Services

View raw message