You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@pulsar.apache.org by Apache Pulsar Slack <ap...@gmail.com> on 2019/08/22 09:11:03 UTC
Slack digest for #general - 2019-08-22
2019-08-21 09:16:10 UTC - Vladimir Shchur: Hi! I'm experiencing the possible bug with RedeliverUnacknowledgedMessages that if I we have 10 messages produced, I acknowledge first five and send redeliver for just 6-8, then 9 and 10 also get redelivered, is it an expected behavior? (2.4.0 version)
----
2019-08-21 09:18:04 UTC - Penghui Li: Do you enable messages batching at producer ?
----
2019-08-21 09:18:28 UTC - Vladimir Shchur: No, I didn't
----
2019-08-21 09:19:40 UTC - Penghui Li: Default is enabled
----
2019-08-21 09:20:20 UTC - Vladimir Shchur: Yeah, I'm writing a .net client, so it's not even implemented yet :smiley:
----
2019-08-21 09:22:13 UTC - Penghui Li: The consumer is also a .net client?
----
2019-08-21 09:24:41 UTC - Vladimir Shchur: Yes, so I'm testing how redelivery calls work. But anyway let me try reproducing it with Java client as well. Will update later.
+1 : Penghui Li
----
2019-08-21 09:33:54 UTC - Bon: @Bon has joined the channel
----
2019-08-21 09:36:25 UTC - Vladimir Shchur: No, looks like I can't test it in Java since client doesn't expose RedeliverUnacknowledgedMessages which takes only specific message ids
----
2019-08-21 09:36:56 UTC - Bon: Hi all, I am newbie in Pulsar any document for transactional in Pulsar ? Does it support transactional ?
----
2019-08-21 10:35:36 UTC - Yong Zhang: @Bon There has a document to introduce transactional in pulsar. <https://docs.google.com/document/d/145VYp09JKTw9jAT-7yNyFU255FptB2_B2Fye100ZXDI/edit#heading=h.bm5ainqxosrx>
Pulsar will support in 2.5.0.
----
2019-08-21 13:11:10 UTC - Vinay Aggarwal: Hi All,
I have setup geo replication for a tenant/namespace, but replication is not happening on any topic
----
2019-08-21 13:11:32 UTC - Vinay Aggarwal: Stats of the topic are : {
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"averageMsgSize" : 0.0,
"storageSize" : 116,
"publishers" : [ {
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"averageMsgSize" : 0.0,
"producerId" : 0,
"metadata" : { },
"address" : "/============:49204",
"producerName" : "us-west-0-7",
"connectedSince" : "2019-08-21T13:05:43.591Z",
"clientVersion" : "2.4.0"
} ],
"subscriptions" : {
"defaultSubscription" : {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"msgRateRedeliver" : 0.0,
"msgBacklog" : 0,
"blockedSubscriptionOnUnackedMsgs" : false,
"msgDelayed" : 0,
"unackedMessages" : 0,
"type" : "Exclusive",
"activeConsumerName" : "c8a14",
"msgRateExpired" : 0.0,
"consumers" : [ {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"msgRateRedeliver" : 0.0,
"consumerName" : "c8a14",
"availablePermits" : 999,
"unackedMessages" : 0,
"blockedConsumerOnUnackedMsgs" : false,
"metadata" : { },
"address" : "============:49210",
"connectedSince" : "2019-08-21T13:05:44.109Z",
"clientVersion" : "2.4.0"
} ],
"isReplicated" : false
}
},
"replication" : {
"us-central" : {
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"msgRateExpired" : 0.0,
"replicationBacklog" : 1,
"connected" : false,
"replicationDelayInSeconds" : 0
}
},
----
2019-08-21 13:12:10 UTC - Vinay Aggarwal: Messages are replication backlog and connected status is false
----
2019-08-21 13:12:26 UTC - Vinay Aggarwal: Please help in identifying the error
----
2019-08-21 16:50:53 UTC - Luke Lu: That won’t work well with a pulsar namespace with long retention configuration though. It’d be wise to set up separate namespaces for testing though :slightly_smiling_face:
Also: <https://github.com/apache/pulsar/issues/5005>
----
2019-08-21 20:58:06 UTC - jialin liu: @jialin liu has joined the channel
----
2019-08-21 21:06:39 UTC - jialin liu: Hi, I run into this error, can anyone help me?
----
2019-08-21 21:06:54 UTC - jialin liu:
----
2019-08-21 21:11:09 UTC - Chris Bartholomew: What are you doing when you see this error?
----
2019-08-21 21:11:25 UTC - jialin liu: I just started the pulsar following the tutorial
----
2019-08-21 21:11:57 UTC - jialin liu: <https://pulsar.apache.org/docs/v1.22.0-incubating/deployment/Kubernetes/>
----
2019-08-21 21:12:45 UTC - jialin liu: $ kubectl apply -f bookie.yaml
$ kubectl apply -f broker.yaml
$ kubectl apply -f monitoring.yaml
$ kubectl apply -f proxy.yaml
----
2019-08-21 21:13:01 UTC - jialin liu: after running the above cmds
----
2019-08-21 21:13:17 UTC - jialin liu: I checked the pods status, all three brokers are not running
----
2019-08-21 21:13:48 UTC - jialin liu: I then saw this error on kb dashboard
----
2019-08-21 21:14:12 UTC - Chris Bartholomew: That link is for an old version. This is the latest doc: <https://pulsar.apache.org/docs/en/deploy-kubernetes/>
----
2019-08-21 21:14:51 UTC - jialin liu: interesting, thanks, let me try again
----
2019-08-21 21:17:25 UTC - Chris Bartholomew: OK, ping me if you run into trouble.
----
2019-08-22 02:22:40 UTC - Bon: many thanks u somuch.
----
2019-08-22 05:50:44 UTC - Vinay Aggarwal: Hi All,
Can someone help with geo replication?
----
2019-08-22 08:19:18 UTC - Jan-Pieter George: @Vladimir Shchur FYI: <https://apache-pulsar.slack.com/archives/C5Z4T36F7/p1565769709133200>
@dba is working on a library there
----
2019-08-22 08:21:09 UTC - Vladimir Shchur: Yeah, we are in contact with him. As soon as both libs are available in nuget we'll see how they compete
----
2019-08-22 08:23:27 UTC - Vladimir Shchur: @Jan-Pieter George By the way you can already try my lib by referencing it's sources <https://github.com/fsharplang-ru/pulsar-client-dotnet>
----
2019-08-22 08:45:21 UTC - divyasree: @Sijie Guo When creating a configuration store common to all DCs, Do we need to have pulsar up and running in that store or its this a common store,(node), which we can specify both all DCs?
----