EugenDueck commented on issue #6209: [broker] add feature BrokerDeduplicationAcrossProducers URL: https://github.com/apache/pulsar/pull/6209#issuecomment-582111237 > * Having a failover-like scenario, where only 1 producer is active and the `client.createProducer()` hangs until a particular producer instance becomes active. Makes sense. I guess you mean to say "until the currently active producer becomes inactive". A waiting producer could continuously ring buffer the last couple of seconds worth of messages, and when it becomes active, it would flush that buffer, mostly leading to (deduplicatable) duplicates, but preventing a gap between where the failed producer left off and the new producer continues. I'll continue working on active/active first though, which is useful in cases where a subset of the active producers may have occasional gaps, e.g. due to UDP packet loss, which would be filled by some other active producer.
---------------------------------------------------------------- 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] With regards, Apache Git Services
