xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890242
##
File path: pulsar/impl_partition_consumer.go
##
@@ -650,27 +682,31 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890214
##
File path: pulsar/impl_partition_consumer.go
##
@@ -610,12 +639,15 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890374
##
File path: pulsar/impl_partition_consumer.go
##
@@ -650,27 +682,31 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890187
##
File path: pulsar/impl_partition_consumer.go
##
@@ -312,23 +311,53 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329889635
##
File path: pulsar/impl_partition_consumer.go
##
@@ -22,6 +22,7 @@ import (
"
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890290
##
File path: pulsar/impl_partition_consumer.go
##
@@ -650,27 +682,31 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329889857
##
File path: pulsar/impl_partition_consumer.go
##
@@ -265,21 +264,21 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890335
##
File path: pulsar/impl_partition_consumer.go
##
@@ -650,27 +682,31 @@ func (pc *part
xujianhai666 commented on a change in pull request #61: [issue:60] Fix
partition topic message router logic
URL: https://github.com/apache/pulsar-client-go/pull/61#discussion_r329890151
##
File path: pulsar/impl_partition_consumer.go
##
@@ -312,23 +311,53 @@ func (pc *part
xujianhai666 commented on a change in pull request #65: [Issue 64] fix bug:
type assert cause panic
URL: https://github.com/apache/pulsar-client-go/pull/65#discussion_r329888718
##
File path: pulsar/impl_partition_producer.go
##
@@ -293,14 +293,17 @@ func (p *partitionProd
xujianhai666 opened a new pull request #69: [ISSUE #68][feat]add Option for new
producer (#68)
URL: https://github.com/apache/pulsar-client-go/pull/69
Change-Id: I85a9c9f20e61e126b617eab919d2405a3ebda087
Master Issue: #68
### Motivation
simple initialization of Produce
massakam commented on issue #5288: [pulsar-broker] Close previous dispatcher
when subscription type changes
URL: https://github.com/apache/pulsar/pull/5288#issuecomment-536830065
rerun cpp tests
rerun integration tests
Thi
rdhabalia commented on issue #5298: [pulsar-broker] Fix: invalidate cache on
zk-cache timeout
URL: https://github.com/apache/pulsar/pull/5298#issuecomment-536821310
@merlimat
i have added a test which simulates the exact scenario and fails without
this change and it invalidates cache w
xujianhai666 opened a new issue #68: Use ConfigOption with for simple usage
URL: https://github.com/apache/pulsar-client-go/issues/68
**Is your feature request related to a problem? Please describe.**
now, when we use client 、producer、consumer, we must provide CleintOption
ProducerOp
tuteng commented on issue #5292: [Doc] Add *Solr sink connector guide*
URL: https://github.com/apache/pulsar/pull/5292#issuecomment-536807186
run java8 tests
This is an automated message from the Apache Git Service.
To respond
xujianhai666 opened a new pull request #67: refactor: remove extra timeout param
URL: https://github.com/apache/pulsar-client-go/pull/67
Change-Id: I9d5d544808a6f739d79776a4f154d7caceaa133c
### Motivation
remove extra timeout param on UnackedMessageTracker#handlerCmd
### Mod
rdhabalia opened a new pull request #5298: [pulsar-broker] Fix: invalidate
cache on zk-cache timeout
URL: https://github.com/apache/pulsar/pull/5298
### Motivation
Right now, while creating producer/consumer, broker tries to authorize them
by fetching namespace policies using zkCach
merlimat commented on issue #5297: Don't attempt to append on read-only cursor
ledger
URL: https://github.com/apache/pulsar/pull/5297#issuecomment-536751955
run integration tests
This is an automated message from the Apache G
jerrypeng commented on issue #5271: Improve error handling logic for
effectively once
URL: https://github.com/apache/pulsar/pull/5271#issuecomment-536747819
rerun integration tests
This is an automated message from the Apache
rdhabalia commented on issue #5276: Fixed race condition while triggering
message redelivery after an ack-timeout event
URL: https://github.com/apache/pulsar/pull/5276#issuecomment-536719899
rerun java8 tests
This is an autom
vzhikserg commented on issue #5205: [doc] Fix broken links to the info about
schemas and Schema Registry
URL: https://github.com/apache/pulsar/pull/5205#issuecomment-536692594
run integration tests
This is an automated messag
merlimat commented on a change in pull request #5276: Fixed race condition
while triggering message redelivery after an ack-timeout event
URL: https://github.com/apache/pulsar/pull/5276#discussion_r329706992
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service
merlimat opened a new pull request #5297: Don't attempt to append on read-only
cursor ledger
URL: https://github.com/apache/pulsar/pull/5297
### Motivation
When the cursor is recovered from a ledger, the ledgerHandle is kept open so
that we can delete that ledger after we update the
rdhabalia commented on a change in pull request #5276: Fixed race condition
while triggering message redelivery after an ack-timeout event
URL: https://github.com/apache/pulsar/pull/5276#discussion_r329693205
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/servic
merlimat commented on a change in pull request #5293: [ISSUE #4675][docs] Add
*Delayed Message Delivery*
URL: https://github.com/apache/pulsar/pull/5293#discussion_r329680805
##
File path: site2/docs/concepts-messaging.md
##
@@ -411,4 +411,32 @@ Message deduplication make
merlimat commented on issue #5276: Fixed race condition while triggering
message redelivery after an ack-timeout event
URL: https://github.com/apache/pulsar/pull/5276#issuecomment-536646537
rerun java8 tests
This is a
merlimat commented on issue #5295: [Doc]to fix syntax err in the sample code:
close producer async
URL: https://github.com/apache/pulsar/pull/5295#issuecomment-536646113
run integration tests
run cpp tests
This is an autom
codelipenghui commented on issue #5288: [pulsar-broker] Close previous
dispatcher when subscription type changes
URL: https://github.com/apache/pulsar/pull/5288#issuecomment-536610573
retest this please
This is an automated m
This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new da04dbe Update io-cdc-canal.md (#5266)
da04dbe
jiazhai merged pull request #5266: Update io-cdc-canal.md
URL: https://github.com/apache/pulsar/pull/5266
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
tomix1337 commented on issue #5266: Update io-cdc-canal.md
URL: https://github.com/apache/pulsar/pull/5266#issuecomment-536583001
@tuteng can we merge? Everything should be ready.
This is an automated message from the Apache G
Anonymitaet commented on issue #5291: [Doc] Add *Redis sink connector guide*
URL: https://github.com/apache/pulsar/pull/5291#issuecomment-536547443
run cpp tests
run integration tests
This is an automated message from the A
Anonymitaet commented on issue #5290: [Doc] Add *RabbitMQ sink connector guide*
URL: https://github.com/apache/pulsar/pull/5290#issuecomment-536547125
run integration tests
This is an automated message from the Apache Git
Anonymitaet commented on issue #5291: [Doc] Add *Redis sink connector guide*
URL: https://github.com/apache/pulsar/pull/5291#issuecomment-536547076
run cpp tests
run integration tests
run java8 tests
This is an automated
Anonymitaet removed a comment on issue #5291: [Doc] Add *Redis sink connector
guide*
URL: https://github.com/apache/pulsar/pull/5291#issuecomment-536546908
retest
This is an automated message from the Apache Git Service.
To r
Anonymitaet commented on issue #5291: [Doc] Add *Redis sink connector guide*
URL: https://github.com/apache/pulsar/pull/5291#issuecomment-536546908
retest
This is an automated message from the Apache Git Service.
To respond to
yittg commented on issue #5165: [PIP-43] Support producer to send msg with
different schema
URL: https://github.com/apache/pulsar/pull/5165#issuecomment-536546873
@sijie @codelipenghui @congbobo184 May I take up some more of your time to
PUSH this PR on.
--
Anonymitaet commented on issue #5296: [Doc] Update connector guide overall
URL: https://github.com/apache/pulsar/pull/5296#issuecomment-536545980
@tuteng could you please help review? Thank you
This is an automated message fro
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524149120
I've created the following PRs to resolve this issue:
# Overview
* https://github.com/apache/pulsar/pull/5183
* https://githu
Anonymitaet opened a new pull request #5296: [Doc] Update connector guide
overall
URL: https://github.com/apache/pulsar/pull/5296
Fix https://github.com/apache/pulsar/issues/5015
This is an automated message from the Apache G
xujianhai666 commented on a change in pull request #5293: [ISSUE #4675][docs]
Add *Delayed Message Delivery*
URL: https://github.com/apache/pulsar/pull/5293#discussion_r329529524
##
File path: site2/docs/concepts-messaging.md
##
@@ -411,4 +411,32 @@ Message deduplication
xujianhai666 commented on a change in pull request #5293: [ISSUE #4675][docs]
Add *Delayed Message Delivery*
URL: https://github.com/apache/pulsar/pull/5293#discussion_r329529414
##
File path: site2/docs/concepts-messaging.md
##
@@ -411,4 +411,32 @@ Message deduplication
xujianhai666 commented on a change in pull request #5293: [ISSUE #4675][docs]
Add *Delayed Message Delivery*
URL: https://github.com/apache/pulsar/pull/5293#discussion_r329526225
##
File path: site2/docs/concepts-messaging.md
##
@@ -411,4 +411,32 @@ Message deduplication
tuteng edited a comment on issue #5294: Getting errors when creating JWT
URL: https://github.com/apache/pulsar/issues/5294#issuecomment-536501144
Can you write more detailed information, such as the version of the pulsar,
whether there are exceptions thrown, and if so, what are the exceptio
tuteng commented on issue #5292: [Doc] Add *Solr sink connector guide*
URL: https://github.com/apache/pulsar/pull/5292#issuecomment-536501819
run java8 tests
This is an automated message from the Apache Git Service.
To respond
tuteng commented on issue #5291: [Doc] Add *Redis sink connector guide*
URL: https://github.com/apache/pulsar/pull/5291#issuecomment-536501577
run cpp tests
This is an automated message from the Apache Git Service.
To respond
tuteng commented on issue #5294: Getting errors when creating JWT
URL: https://github.com/apache/pulsar/issues/5294#issuecomment-536501144
Can you write more detailed information, such as the version of the pulsar,
whether there are exceptions thrown, and if so, what are the exceptions?
@L
kevenYLi opened a new pull request #5295: [Doc]to fix syntax err in the sample
code: close producer async
URL: https://github.com/apache/pulsar/pull/5295
### Motivation
* to fix syntax err in the sample code: 'Close operations can also be
asynchronous’, the error are as below:
tuteng commented on issue #5266: Update io-cdc-canal.md
URL: https://github.com/apache/pulsar/pull/5266#issuecomment-536497548
run integration tests
This is an automated message from the Apache Git Service.
To respond to the m
tuteng commented on a change in pull request #5292: [Doc] Add *Solr sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5292#discussion_r329503738
##
File path: site2/docs/io-solr-sink.md
##
@@ -0,0 +1,60 @@
+---
+id: io-solr-sink
+title: Solr sink connector
+
Anonymitaet commented on a change in pull request #5291: [Doc] Add *Redis sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5291#discussion_r329503631
##
File path: site2/docs/io-redis-sink.md
##
@@ -0,0 +1,69 @@
+---
+id: io-redis-sink
+title: Redis sink co
Anonymitaet commented on a change in pull request #5291: [Doc] Add *Redis sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5291#discussion_r329503528
##
File path: site2/docs/io-redis-sink.md
##
@@ -0,0 +1,69 @@
+---
+id: io-redis-sink
+title: Redis sink co
Anonymitaet commented on a change in pull request #5291: [Doc] Add *Redis sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5291#discussion_r329503528
##
File path: site2/docs/io-redis-sink.md
##
@@ -0,0 +1,69 @@
+---
+id: io-redis-sink
+title: Redis sink co
Anonymitaet commented on a change in pull request #5289: [Doc] Add *MongoDB
sink connector guide*
URL: https://github.com/apache/pulsar/pull/5289#discussion_r329502787
##
File path: site2/docs/io-mongo-sink.md
##
@@ -0,0 +1,51 @@
+---
+id: io-mongo-sink
+title: MongoDB sin
Anonymitaet commented on a change in pull request #5289: [Doc] Add *MongoDB
sink connector guide*
URL: https://github.com/apache/pulsar/pull/5289#discussion_r329502771
##
File path: site2/docs/io-mongo-sink.md
##
@@ -0,0 +1,51 @@
+---
+id: io-mongo-sink
+title: MongoDB sin
tuteng commented on a change in pull request #5291: [Doc] Add *Redis sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5291#discussion_r329502037
##
File path: site2/docs/io-redis-sink.md
##
@@ -0,0 +1,69 @@
+---
+id: io-redis-sink
+title: Redis sink connect
tuteng commented on a change in pull request #5291: [Doc] Add *Redis sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5291#discussion_r329502060
##
File path: site2/docs/io-redis-sink.md
##
@@ -0,0 +1,69 @@
+---
+id: io-redis-sink
+title: Redis sink connect
tuteng commented on a change in pull request #5289: [Doc] Add *MongoDB sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5289#discussion_r329497951
##
File path: site2/docs/io-mongo-sink.md
##
@@ -0,0 +1,51 @@
+---
+id: io-mongo-sink
+title: MongoDB sink con
tuteng commented on a change in pull request #5289: [Doc] Add *MongoDB sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5289#discussion_r329497914
##
File path: site2/docs/io-mongo-sink.md
##
@@ -0,0 +1,51 @@
+---
+id: io-mongo-sink
+title: MongoDB sink con
Loghijiaha opened a new issue #5294: Getting errors when creating JWT
URL: https://github.com/apache/pulsar/issues/5294
**Describe the bug**
I created private/public key pairs using :
`$ bin/pulsar tokens create-key-pair --output-private-key my-private.key
--output-public-key my-p
60 matches
Mail list logo
