2020-08-19 10:29:47 UTC - Arul: @Arul has joined the channel ---- 2020-08-19 14:55:22 UTC - Maksym Domarev: @Maksym Domarev has joined the channel ---- 2020-08-19 17:22:22 UTC - ckdarby: We've gone through the docs looking to see if Pulsar functions support a window method? Is it possible to have the Pulsar function "flush" it's state every Y time or N events? ---- 2020-08-19 23:19:30 UTC - Maksym Domarev: I have weird responses order when doing nack. I’m sending 9 messages from 0 to 9, and start consuming it, if message = 5 I’m doing nack two times, if it’s more then that, I allow message to be acked. Results are : 1. `Exclusive mode` : 0, 1, 2, 3, 4, nack [counter =1 ] one , 6, 7, 8, 9, nack[counter = 2], 6, ,7 , 8, 9 , 5 . The second 6 7 8 9 are actually duplicating. 2. SharedKey same behavior Config : > options := pulsar.ConsumerOptions{ > Topic: topic, > SubscriptionName: cg, > Type: pulsar.Exclusive, > ReceiverQueueSize: 2, > NackRedeliveryDelay: 100 * time.Millisecond, > } > ---- 2020-08-19 23:20:13 UTC - Maksym Domarev: Is there any way to avoid duplicates, and keep order ? Client is Golang ---- 2020-08-20 02:38:38 UTC - Ryan Nowacoski: If someone has time a review on this PR would be helpful, thanks in advance! <https://github.com/apache/pulsar/pull/7855> ----