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

Reply via email to