[GitHub] [pulsar-client-go] cckellogg opened a new pull request #134: Exit go routine when signal is caught.
cckellogg opened a new pull request #134: Exit go routine when signal is caught. URL: https://github.com/apache/pulsar-client-go/pull/134 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: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (dc80d29 -> 0ec1abf)
This is an automated email from the ASF dual-hosted git repository. hjf pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from dc80d29 [docs]Refine "The Pulsar Java client" content (#5853) add 0ec1abf [blog] Refine format issues for Pulsar 2.4.2 release blog (#5893) No new revisions were added by this update. Summary of changes: site2/website/blog/2019-12-04-Apache-Pulsar-2-4-2.md | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-)
[GitHub] [pulsar-client-go] merlimat opened a new pull request #133: Removed unused config options
merlimat opened a new pull request #133: Removed unused config options URL: https://github.com/apache/pulsar-client-go/pull/133 ### Motivation There are some config options that are currently ignored in the Go client and make more sense in C++ client lib. Removing them for now, until it's clear that we need them. 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: us...@infra.apache.org With regards, Apache Git Services
[pulsar-client-go] branch master updated: Move pkg stuff under pulsar/internal (#132)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new de66846 Move pkg stuff under pulsar/internal (#132)
de66846 is described below
commit de668469aa52d2c155545fc65a6cd16a208b74fc
Author: Matteo Merli
AuthorDate: Wed Dec 18 22:04:42 2019 -0800
Move pkg stuff under pulsar/internal (#132)
* Move pkg stuff under pulsar/internal
* Fixed exclude path
---
integration-tests/license_test.go| 2 +-
pulsar/client.go | 2 +-
pulsar/client_impl.go| 4 ++--
pulsar/consumer_impl.go | 2 +-
pulsar/consumer_partition.go | 4 ++--
pulsar/helper.go | 2 +-
pulsar/impl_message.go | 2 +-
{pkg => pulsar/internal}/auth/disabled.go| 0
{pkg => pulsar/internal}/auth/provider.go| 0
{pkg => pulsar/internal}/auth/tls.go | 0
{pkg => pulsar/internal}/auth/token.go | 0
pulsar/internal/batch_builder.go | 4 ++--
pulsar/internal/commands.go | 2 +-
{pkg => pulsar/internal}/compression/compression.go | 0
{pkg => pulsar/internal}/compression/compression_test.go | 0
{pkg => pulsar/internal}/compression/lz4.go | 0
{pkg => pulsar/internal}/compression/noop.go | 0
{pkg => pulsar/internal}/compression/zlib.go | 0
{pkg => pulsar/internal}/compression/zstd.go | 0
pulsar/internal/connection.go| 4 ++--
pulsar/internal/connection_pool.go | 2 +-
pulsar/internal/connection_reader.go | 2 +-
pulsar/internal/lookup_service.go| 2 +-
pulsar/internal/lookup_service_test.go | 2 +-
{pkg => pulsar/internal}/pb/PulsarApi.pb.go | 0
pulsar/internal/rpc_client.go| 2 +-
pulsar/producer_partition.go | 2 +-
27 files changed, 20 insertions(+), 20 deletions(-)
diff --git a/integration-tests/license_test.go
b/integration-tests/license_test.go
index 2613e25..02794de 100644
--- a/integration-tests/license_test.go
+++ b/integration-tests/license_test.go
@@ -65,7 +65,7 @@ var otherCheck = regexp.MustCompile(`#
`)
var skip = map[string]bool{
- "../pkg/pb/PulsarApi.pb.go": true,
+ "../pulsar/internal/pb/PulsarApi.pb.go": true,
}
func TestLicense(t *testing.T) {
diff --git a/pulsar/client.go b/pulsar/client.go
index 6916371..36c69a6 100644
--- a/pulsar/client.go
+++ b/pulsar/client.go
@@ -20,7 +20,7 @@ package pulsar
import (
"time"
- "github.com/apache/pulsar-client-go/pkg/auth"
+ "github.com/apache/pulsar-client-go/pulsar/internal/auth"
)
func NewClient(options ClientOptions) (Client, error) {
diff --git a/pulsar/client_impl.go b/pulsar/client_impl.go
index d0c36fe..6e8a910 100644
--- a/pulsar/client_impl.go
+++ b/pulsar/client_impl.go
@@ -26,9 +26,9 @@ import (
log "github.com/sirupsen/logrus"
- "github.com/apache/pulsar-client-go/pkg/auth"
- "github.com/apache/pulsar-client-go/pkg/pb"
"github.com/apache/pulsar-client-go/pulsar/internal"
+ "github.com/apache/pulsar-client-go/pulsar/internal/auth"
+ "github.com/apache/pulsar-client-go/pulsar/internal/pb"
)
type client struct {
diff --git a/pulsar/consumer_impl.go b/pulsar/consumer_impl.go
index 752b0f3..61c27a7 100644
--- a/pulsar/consumer_impl.go
+++ b/pulsar/consumer_impl.go
@@ -27,8 +27,8 @@ import (
log "github.com/sirupsen/logrus"
- "github.com/apache/pulsar-client-go/pkg/pb"
"github.com/apache/pulsar-client-go/pulsar/internal"
+ "github.com/apache/pulsar-client-go/pulsar/internal/pb"
)
var ErrConsumerClosed = errors.New("consumer closed")
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
index 68ee7af..81cb9ad 100644
--- a/pulsar/consumer_partition.go
+++ b/pulsar/consumer_partition.go
@@ -26,9 +26,9 @@ import (
log "github.com/sirupsen/logrus"
- "github.com/apache/pulsar-client-go/pkg/compression"
- "github.com/apache/pulsar-client-go/pkg/pb"
"github.com/apache/pulsar-client-go/pulsar/internal"
+ "github.com/apache/pulsar-client-go/pulsar/internal/compression"
+ "github.com/apache/pulsar-client-go/pulsar/internal/pb"
)
var (
diff --git a/pulsar/helper.go b/pulsar/helper.go
index 2591f52..5c9b54d 100644
--- a/pulsar/helper.go
+++ b/pulsar/helper.go
@@ -24,8 +24,8 @@ import (
"github.com/golang/protobuf/proto"
- "github.com/apache/pulsar-client-go/pkg/pb"
[pulsar-client-go] branch master updated (4ffced1 -> 1ac8a8b)
This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git. from 4ffced1 fix requestID using consumerID && loopclosure issue && add old style topic support (#128) add 1ac8a8b Fixed detection and handling of stale connections (#131) No new revisions were added by this update. Summary of changes: pulsar/internal/connection.go| 80 +--- pulsar/internal/connection_reader.go | 8 ++-- pulsar/producer_partition.go | 28 - 3 files changed, 87 insertions(+), 29 deletions(-)
[GitHub] [pulsar] ltamber opened a new issue #5597: [pulsar-client-java] retry when getPartitionedTopicMetadata failed
ltamber opened a new issue #5597: [pulsar-client-java] retry when getPartitionedTopicMetadata failed URL: https://github.com/apache/pulsar/issues/5597 **Is your feature request related to a problem? Please describe.** when pulsar client create producer async, we can provide a serviceUrl with multi service address divided by comma, but when the connection to the first address failed or other exception, the producer init will fail. **Describe the solution you'd like** we can retry the other addresses 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: us...@infra.apache.org With regards, Apache Git Services
[pulsar-client-go] branch master updated: fix requestID using consumerID && loopclosure issue && add old style topic support (#128)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 4ffced1 fix requestID using consumerID && loopclosure issue && add
old style topic support (#128)
4ffced1 is described below
commit 4ffced1ae42a96553fd15f6cc295a22b2eb41674
Author: hailang.wei <5317064+archf...@users.noreply.github.com>
AuthorDate: Thu Dec 19 11:36:37 2019 +0800
fix requestID using consumerID && loopclosure issue && add old style topic
support (#128)
* fix requestID using consumerID
* fix loopclosure issue
* add old style topic support
---
pulsar/consumer_partition.go | 2 +-
pulsar/consumer_regex.go | 2 +-
pulsar/internal/topic_name.go | 5 +++--
pulsar/internal/topic_name_test.go | 14 ++
4 files changed, 15 insertions(+), 8 deletions(-)
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
index a217d55..68ee7af 100644
--- a/pulsar/consumer_partition.go
+++ b/pulsar/consumer_partition.go
@@ -465,7 +465,7 @@ func (pc *partitionConsumer) internalClose(req
*closeRequest) {
pc.state = consumerClosing
pc.log.Infof("Closing consumer=%d", pc.consumerID)
- requestID := pc.client.rpcClient.NewConsumerID()
+ requestID := pc.client.rpcClient.NewRequestID()
cmdClose := {
ConsumerId: proto.Uint64(pc.consumerID),
RequestId: proto.Uint64(requestID),
diff --git a/pulsar/consumer_regex.go b/pulsar/consumer_regex.go
index aa57356..e68c495 100644
--- a/pulsar/consumer_regex.go
+++ b/pulsar/consumer_regex.go
@@ -351,7 +351,7 @@ func subscriber(c *client, topics []string, opts
ConsumerOptions, ch chan Consum
c, err := internalTopicSubscribe(c, opts, topic, ch)
consumerErrorCh <- consumerError{
err: err,
- topic:t,
+ topic:topic,
consumer: c,
}
}(t)
diff --git a/pulsar/internal/topic_name.go b/pulsar/internal/topic_name.go
index f5b9890..78d2abb 100644
--- a/pulsar/internal/topic_name.go
+++ b/pulsar/internal/topic_name.go
@@ -44,9 +44,10 @@ func ParseTopicName(topic string) (*TopicName, error) {
if !strings.Contains(topic, "://") {
// The short topic name can be:
// -
- // - //
+ // - //
+ // - ///
parts := strings.Split(topic, "/")
- if len(parts) == 3 {
+ if len(parts) == 3 || len(parts) == 4 {
topic = "persistent://" + topic
} else if len(parts) == 1 {
topic = "persistent://" + publicTenant + "/" +
defaultNamespace + "/" + parts[0]
diff --git a/pulsar/internal/topic_name_test.go
b/pulsar/internal/topic_name_test.go
index 738ab22..e57bf4d 100644
--- a/pulsar/internal/topic_name_test.go
+++ b/pulsar/internal/topic_name_test.go
@@ -61,6 +61,12 @@ func TestParseTopicName(t *testing.T) {
assert.Equal(t, "persistent://my-tenant/my-cluster/my-ns/my-topic",
topic.Name)
assert.Equal(t, "my-tenant/my-cluster/my-ns", topic.Namespace)
assert.Equal(t, -1, topic.Partition)
+
+ topic, err = ParseTopicName("my-tenant/my-cluster/my-ns/my-topic")
+ assert.Nil(t, err)
+ assert.Equal(t, "persistent://my-tenant/my-cluster/my-ns/my-topic",
topic.Name)
+ assert.Equal(t, "my-tenant/my-cluster/my-ns", topic.Namespace)
+ assert.Equal(t, -1, topic.Partition)
}
func TestParseTopicNameErrors(t *testing.T) {
@@ -84,16 +90,16 @@ func TestParseTopicNameErrors(t *testing.T) {
}
func TestTopicNameWithoutPartitionPart(t *testing.T) {
- tests := []struct{
- tn TopicName
+ tests := []struct {
+ tn TopicName
expected string
}{
{
- tn:
TopicName{Name:"persistent://public/default/my-topic", Partition:-1},
+ tn: TopicName{Name:
"persistent://public/default/my-topic", Partition: -1},
expected: "persistent://public/default/my-topic",
},
{
- tn:
TopicName{Name:"persistent://public/default/my-topic-partition-0", Partition:0},
+ tn: TopicName{Name:
"persistent://public/default/my-topic-partition-0", Partition: 0},
expected: "persistent://public/default/my-topic",
},
}
[GitHub] [pulsar] Jennifer88huang opened a new pull request #5893: [blog] Refine format issues for Pulsar 2.4.2 release blog
Jennifer88huang opened a new pull request #5893: [blog] Refine format issues for Pulsar 2.4.2 release blog URL: https://github.com/apache/pulsar/pull/5893 ### Motivation There are some format issues for the blog on Pulsar website.  ### Modifications Fix the format and link issue. ### Verifying this change Test locally, and they work well.  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: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (3a2122b -> dc80d29)
This is an automated email from the ASF dual-hosted git repository. hjf pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 3a2122b Fix pulsar build image with maven 3.6.1 (#5886) add dc80d29 [docs]Refine "The Pulsar Java client" content (#5853) No new revisions were added by this update. Summary of changes: site2/docs/client-libraries-java.md | 205 +--- 1 file changed, 95 insertions(+), 110 deletions(-)
[GitHub] [pulsar] cckellogg opened a new pull request #5892: Use BOOKIE_MEM and BOOKIE_GC env vars if set.
cckellogg opened a new pull request #5892: Use BOOKIE_MEM and BOOKIE_GC env vars if set. URL: https://github.com/apache/pulsar/pull/5892 Use BOOKIE_MEM and BOOKIE_GC if they have already been set. This removes the need to overwrite the bkenv.sh config file and this is useful when running in a container environment. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar-client-go] merlimat opened a new pull request #132: Move pkg stuff under pulsar/internal
merlimat opened a new pull request #132: Move pkg stuff under pulsar/internal URL: https://github.com/apache/pulsar-client-go/pull/132 ### Motivation I know this was changed in #7, though my concern is that everything under `pkg` is currently publicly visible and thus becomes part of public APIs. Since all the code in there is meant to be strictly private, we should make sure this is easily enforced. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar-client-go] merlimat opened a new pull request #131: Fixed detection and handling of stale connections
merlimat opened a new pull request #131: Fixed detection and handling of stale connections URL: https://github.com/apache/pulsar-client-go/pull/131 ### Motivation This is fixing an issue in which the Ping task is getting stalled when the connection is not writable (eg: network partition with the broker). The checking of connection staleness needs to be done in its own goroutine to ensure it's running even when the write/read routines are blocked. This makes sure clients can successfully recover from partitions and failures with the brokers, also during the initial handshake. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] mprokushenkov opened a new issue #5891: Dead letters incorrect processed for messages batch
mprokushenkov opened a new issue #5891: Dead letters incorrect processed for messages batch URL: https://github.com/apache/pulsar/issues/5891 **Describe the bug** Producer produces 10 messages. Consumer with set deads letters policy acks 9 messages and 1 nacks. This will lead to all 10 messages coming to dead letters topic. **To Reproduce** I'm testing scenario where producer sents messages using batch. Consumer with enabled dead letters policy acks all messages but nacks one message. Then another consumer receives messages from dead letters topic. Steps to reproduce the behavior: 1. Instanciate producer with enabled batching 2. Instanciate consumer with enabled dead letters policy (maxRedeliverCount should be equals 0) 3. Instanciate consumer for receiving messages from dead letters topic 4. Send 10 messages 5. Receive all messages and ack first 9 but nack for last (10) 6. Receive messages from dead letters queue **Expected behavior** I expect that only nacked (10) message will be received from dead letters queue. **Screenshots** Here is a screenshot of log messages produced by steps specified above:  In [Step 3] only last (10) message should be received. **Desktop (please complete the following information):** - OS: Windows - Environment: docker - Pulsar version: 2.4.1 **Additional context** No additional context. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar-client-go] merlimat opened a new pull request #130: Allow to specify a function that supply a token
merlimat opened a new pull request #130: Allow to specify a function that supply a token URL: https://github.com/apache/pulsar-client-go/pull/130 ### Motivation Similarly to the C++ based Go client and to Java, C++ and Py APIs, we need to allow application to specify a function provider for the token itself. This is required in all scenarios where tokens are refreshed and not written on a file. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] alex-rufo opened a new pull request #5890: Allow routing key per message to RabbitMQ sink connector
alex-rufo opened a new pull request #5890: Allow routing key per message to RabbitMQ sink connector URL: https://github.com/apache/pulsar/pull/5890 ### Motivation With the current RabbitMQ sink connector, all messages are forwarded to an exchange with the same routing key (specified in the configuration). It would be great to give a bit more flexibility and allow the use of different routing keys for different messages on the same topic. ### Modifications The creation of the queue has been removed from the sink, all messages will be forwarded to the exchange and each consumer will create it's on queue + binding. The configuration has been modified to reflect those changes: added the exchange type and queue name is just required for the source connector. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar-client-go] wolfstudy opened a new issue #129: The consumer can't Unsubscribe correctly in Failover sub mode
wolfstudy opened a new issue #129: The consumer can't Unsubscribe correctly in
Failover sub mode
URL: https://github.com/apache/pulsar-client-go/issues/129
Steps to reproduce
run code as follows:
```
func TestSubFailOver(t *testing.T) {
client, err := NewClient(ClientOptions{
URL: lookupURL,
})
if err != nil {
t.Fatal(err)
}
topic := "test-failover-topic-4"
subName := "test-sub-4"
producer, err := client.CreateProducer(ProducerOptions{
Topic: topic,
})
assert.Nil(t, err)
for i := 0; i < 30; i++ {
err = producer.Send(context.Background(), {
Payload: []byte(fmt.Sprintf("message-%d", i)),
})
assert.Nil(t, err)
}
cfg := ConsumerOptions{
Topic:topic,
SubscriptionName: subName,
Type: Failover,
SubscriptionInitialPosition: SubscriptionPositionEarliest,
}
consumer1, err := client.Subscribe(cfg)
assert.Nil(t, err)
consumer2, err := client.Subscribe(cfg)
assert.Nil(t, err)
consumer3, err := client.Subscribe(cfg)
assert.Nil(t, err)
go func(consumer1 Consumer) {
for {
msg, err := consumer1.Receive(context.Background())
assert.Nil(t, err)
fmt.Printf("consumer-1 receive : %s\n", string(msg.Payload()))
}
}(consumer1)
go func(consumer2 Consumer) {
for {
msg, err := consumer2.Receive(context.Background())
assert.Nil(t, err)
fmt.Printf("consumer-2 receive : %s\n", string(msg.Payload()))
}
}(consumer2)
go func(consumer3 Consumer) {
for {
msg, err := consumer3.Receive(context.Background())
assert.Nil(t, err)
fmt.Printf("consumer-3 receive : %s\n", string(msg.Payload()))
}
}(consumer3)
time.Sleep(time.Second * 10)
consumer1.Unsubscribe()
consumer1.Close()
consumer2.Unsubscribe()
consumer2.Close()
consumer3.Unsubscribe()
consumer3.Close()
}
```
System configuration
**Pulsar version**: 2.5.0
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:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] jiazhai opened a new pull request #5889: fix some typos in the comments
jiazhai opened a new pull request #5889: fix some typos in the comments URL: https://github.com/apache/pulsar/pull/5889 fix some typos in the comments 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Lanayx edited a comment on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2
Lanayx edited a comment on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2 URL: https://github.com/apache/pulsar/issues/5877#issuecomment-566934339 Looks like the problem is not on client side, since the same behavior is seen on Java client 2.4.1, 2.4.2 and .net client that I'm developing. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Lanayx commented on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2
Lanayx commented on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2 URL: https://github.com/apache/pulsar/issues/5877#issuecomment-566934339 Looks like the problem is not on consumer side, since the same behavior is seen on Java client 2.4.1, 2.4.2 and .net client that I'm developing. 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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Lanayx edited a comment on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2
Lanayx edited a comment on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2 URL: https://github.com/apache/pulsar/issues/5877#issuecomment-566930136 Broker's logs   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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Lanayx commented on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2
Lanayx commented on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2 URL: https://github.com/apache/pulsar/issues/5877#issuecomment-566930136 Broker's logs   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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Lanayx edited a comment on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2
Lanayx edited a comment on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2 URL: https://github.com/apache/pulsar/issues/5877#issuecomment-566927522 Here are some stats, I can see 24 messages in backlog, and connected consumers, but those messages are not being delivered until consumers reconnect    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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Lanayx commented on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2
Lanayx commented on issue #5877: Shared subscription doesn't work well with partitioned topic in 2.4.2 URL: https://github.com/apache/pulsar/issues/5877#issuecomment-566927522 Here are some stats, it's visible here 24 messages in backlog, and connected consumers, but those messages are not delivered until consumers reconnect    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: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] PierreZ commented on issue #5802: Provide raw counters metrics (#5735)
PierreZ commented on issue #5802: Provide raw counters metrics (#5735) URL: https://github.com/apache/pulsar/pull/5802#issuecomment-566922789 Thanks! 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: us...@infra.apache.org With regards, Apache Git Services
