You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by Apache Pulsar Slack <ap...@gmail.com> on 2020/08/20 09:11:03 UTC
Slack digest for #dev - 2020-08-20
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>
----