wolfstudy opened a new pull request #6974:
URL: https://github.com/apache/pulsar/pull/6974
Signed-off-by: xiaolong.ran
### Motivation
Fix 2.4.0 missing docs of cgo client
This is an automated me
wolfstudy opened a new pull request #251:
URL: https://github.com/apache/pulsar-client-go/pull/251
Signed-off-by: xiaolong.ran
Master Issue: #243
### Motivation
- Expose isReplicated and replicatedFrom for Pulsar message
### Modifications
- Add `replicate
yarthur1 commented on pull request #249:
URL: https://github.com/apache/pulsar-client-go/pull/249#issuecomment-629813082
I hope that both before send and time wait for response should check
timeout.I don't want to wait send func always,because I meet this situation
where pulsar broker has
merlimat merged pull request #251:
URL: https://github.com/apache/pulsar-client-go/pull/251
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 t
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 e1c3822 Expose replicated from filed
WJL opened a new pull request #252:
URL: https://github.com/apache/pulsar-client-go/pull/252
<--
### Contribution Checklist
- Name the pull request in the form "[Issue XYZ][component] Title of the
pull request", where *XYZ* should be replaced by the actual issue number.
WJL closed pull request #249:
URL: https://github.com/apache/pulsar-client-go/pull/249
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
WJL commented on pull request #249:
URL: https://github.com/apache/pulsar-client-go/pull/249#issuecomment-629815523
closed and goto https://github.com/apache/pulsar-client-go/pull/252
This is an automated message from the
wolfstudy closed issue #243:
URL: https://github.com/apache/pulsar-client-go/issues/243
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
wolfstudy commented on issue #243:
URL:
https://github.com/apache/pulsar-client-go/issues/243#issuecomment-629817978
The feature will be impled in @251
This is an automated message from the Apache Git Service.
To respond to
rueian commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r426214384
##
File path: pulsar/internal/connection.go
##
@@ -656,18 +662,20 @@ func (c *connection) Close() {
c.log.Info("Connection closed")
rueian commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r426214384
##
File path: pulsar/internal/connection.go
##
@@ -656,18 +662,20 @@ func (c *connection) Close() {
c.log.Info("Connection closed")
merlimat commented on a change in pull request #252:
URL: https://github.com/apache/pulsar-client-go/pull/252#discussion_r426287863
##
File path: pulsar/internal/blocking_queue.go
##
@@ -34,6 +34,11 @@ type BlockingQueue interface {
// Poll dequeue one item, return nil
Huanli-Meng commented on a change in pull request #6974:
URL: https://github.com/apache/pulsar/pull/6974#discussion_r426329764
##
File path: site2/website/versioned_docs/version-2.4.0/client-libraries-go.md
##
@@ -90,6 +90,21 @@ func main() {
}
```
+### Client operations
+
jiazhai commented on issue #6961:
URL: https://github.com/apache/pulsar/issues/6961#issuecomment-629900774
Hi @baynes What is the broker side log shows?
In broker.conf, there is an item:
```
# Max size of messages.
maxMessageSize=5242880
```
Usually you need to config it
jiazhai commented on issue #6960:
URL: https://github.com/apache/pulsar/issues/6960#issuecomment-629902251
@bigbang489 Thanks for reporting this issue, Could this be stable
reproduced? It would be appreciate if you could provide your code example to
reproduce it.
-
cckellogg commented on a change in pull request #6972:
URL: https://github.com/apache/pulsar/pull/6972#discussion_r426335178
##
File path:
pulsar-common/src/test/java/org/apache/pulsar/common/validator/ConfigValidationTest.java
##
@@ -0,0 +1,148 @@
+/**
+ * Licensed to the Apa
jiazhai commented on issue #6962:
URL: https://github.com/apache/pulsar/issues/6962#issuecomment-629903935
@gotopanic Thanks for reporting this issue. Would you like to contribute to
it?
This is an automated message from the
jiazhai commented on issue #6965:
URL: https://github.com/apache/pulsar/issues/6965#issuecomment-629904860
@youzipi Thanks for reporting this issue. We will take a look into it.
This is an automated message from the Apache G
jiazhai commented on issue #6967:
URL: https://github.com/apache/pulsar/issues/6967#issuecomment-629906423
@Mefl Thanks for the issue reporting. Looks like this is a bug in doc
release. Seems 2.5.1 doc included content that should not be included.
@Mefl Would you like to help fix this do
jiazhai commented on issue #6967:
URL: https://github.com/apache/pulsar/issues/6967#issuecomment-629906508
also @tuteng who is the release manager of 2.5.1.
This is an automated message from the Apache Git Service.
To respond
jiazhai commented on issue #6969:
URL: https://github.com/apache/pulsar/issues/6969#issuecomment-629908155
@trexinc Thanks for the reporting of this issue. Would you please help
collect the broker logs when this error happens.
-
jiazhai commented on issue #250:
URL:
https://github.com/apache/pulsar-client-go/issues/250#issuecomment-629909658
@wolfstudy Would you please help take a look?
This is an automated message from the Apache Git Service.
To re
cckellogg commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r426339996
##
File path: pulsar/internal/connection.go
##
@@ -656,18 +662,20 @@ func (c *connection) Close() {
c.log.Info("Connection closed")
jiazhai commented on pull request #6966:
URL: https://github.com/apache/pulsar/pull/6966#issuecomment-629914223
@massakam Since 2.5.2 was send out for vote, could we add it to 2.5.3?
This is an automated message from the Apac
jiazhai edited a comment on pull request #6471:
URL: https://github.com/apache/pulsar/pull/6471#issuecomment-625732030
For merge conflict. mark as 2.5.2 and cherry-picked into branch-2.5
This is an automated message from the
zr-hebo opened a new pull request #253:
URL: https://github.com/apache/pulsar-client-go/pull/253
Improve the sending performance to 5 message per second, by
- Add buffer pool, avoid make slice every time need getting buffer;
- Increased buffer size in various place.
srkukarni commented on a change in pull request #6972:
URL: https://github.com/apache/pulsar/pull/6972#discussion_r426348720
##
File path:
pulsar-common/src/test/java/org/apache/pulsar/common/validator/ConfigValidationTest.java
##
@@ -0,0 +1,148 @@
+/**
+ * Licensed to the Apa
massakam commented on pull request #6966:
URL: https://github.com/apache/pulsar/pull/6966#issuecomment-629921280
@jiazhai Okay. Changed the release label to 2.5.3.
This is an automated message from the Apache Git Service.
To
rueian commented on a change in pull request #248:
URL: https://github.com/apache/pulsar-client-go/pull/248#discussion_r426358653
##
File path: pulsar/internal/connection.go
##
@@ -656,18 +662,20 @@ func (c *connection) Close() {
c.log.Info("Connection closed")
lukestephenson commented on issue #6950:
URL: https://github.com/apache/pulsar/issues/6950#issuecomment-629935323
@sijie Thanks for pointing me at the new repo. When will the new repo
become the official one that the pulsar deployment docs are pointed to? Thanks
wolfstudy commented on issue #188:
URL:
https://github.com/apache/pulsar-client-go/issues/188#issuecomment-629945755
@zxbfeng As @cckellogg said, will close this issue, If there is any problem
please reopen it
This is a
wolfstudy closed issue #188:
URL: https://github.com/apache/pulsar-client-go/issues/188
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
WJL commented on pull request #252:
URL: https://github.com/apache/pulsar-client-go/pull/252#issuecomment-629949404
hi，this pr has some bad test case，i'm working on it. any suggestions？i'm new
to unit test.
This is an au
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git.
from e1c3822 Expose replicated from filed on message struct (#251)
add bc647c6 Fix data race when accessing
wolfstudy merged pull request #215:
URL: https://github.com/apache/pulsar-client-go/pull/215
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
wolfstudy closed issue #213:
URL: https://github.com/apache/pulsar-client-go/issues/213
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
WJL edited a comment on pull request #252:
URL: https://github.com/apache/pulsar-client-go/pull/252#issuecomment-629949404
hi, this pr has some bad test case, i'm working on it. any suggestions？i'm
new to unit test.
and i found in some case send timeout is a bit longer then expect. t
This is an automated email from the ASF dual-hosted git repository.
jerrypeng 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 7a76954 Modify ThreadRuntime to allow custom
jerrypeng merged pull request #6971:
URL: https://github.com/apache/pulsar/pull/6971
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
wolfstudy merged pull request #6974:
URL: https://github.com/apache/pulsar/pull/6974
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
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7a76954 Modify ThreadRuntime to allow custom secrets providers (#6971)
add f5223fc Fix 2.4.0 missing docs of cgo
wolfstudy opened a new pull request #254:
URL: https://github.com/apache/pulsar-client-go/pull/254
Fixes #208
### Motivation
- Fix send async comments
This is an automated message fr
wolfstudy commented on issue #223:
URL:
https://github.com/apache/pulsar-client-go/issues/223#issuecomment-629962535
> I expect to be able to read `hello-1` as latest message somehow, since
it's the latest message. Your code using `EarliestMessageID()` will read the
`hello-0` message.
wolfstudy commented on pull request #252:
URL: https://github.com/apache/pulsar-client-go/pull/252#issuecomment-629964211
> hi, this pr has some bad test case, i'm working on it. any suggestions？i'm
new to unit test.
> and i found in some case send timeout is a bit longer then expect. tr
dsmlily closed issue #155:
URL: https://github.com/apache/pulsar-client-go/issues/155
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 t
Anonymitaet commented on a change in pull request #254:
URL: https://github.com/apache/pulsar-client-go/pull/254#discussion_r426388616
##
File path: pulsar/producer.go
##
@@ -128,6 +128,8 @@ type Producer interface {
Send(context.Context, *ProducerMessage) (MessageID, e
jiazhai commented on a change in pull request #6684:
URL: https://github.com/apache/pulsar/pull/6684#discussion_r426390027
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java
##
@@ -40,9 +45,18 @@
private Function f
Anonymitaet commented on a change in pull request #254:
URL: https://github.com/apache/pulsar-client-go/pull/254#discussion_r426388616
##
File path: pulsar/producer.go
##
@@ -128,6 +128,8 @@ type Producer interface {
Send(context.Context, *ProducerMessage) (MessageID, e
wolfstudy merged pull request #254:
URL: https://github.com/apache/pulsar-client-go/pull/254
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
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 77f0806 Fix send async comments (#254)
7
wolfstudy closed issue #208:
URL: https://github.com/apache/pulsar-client-go/issues/208
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
wolfstudy commented on issue #241:
URL:
https://github.com/apache/pulsar-client-go/issues/241#issuecomment-629976251
You can try to use the following code example:
```
consumer, err := client.CreateReader(pulsar.ReaderOptions{
Topic: "persistent://public/defau
Huanli-Meng commented on issue #6110:
URL: https://github.com/apache/pulsar/issues/6110#issuecomment-629981440
it seems this bug is fixed. in 2.5.0 and later releases, "connector Admin
CLI" is moved from reference section to Pulsar IO connection. and the doc name
is changed from "connector
youzipi commented on issue #6965:
URL: https://github.com/apache/pulsar/issues/6965#issuecomment-629982830
I checked the UT
`org.apache.pulsar.client.api.SimpleProducerConsumerTest#testPauseAndResume`
```java
log.info("Giving message listener an opportunity to receive messages
youzipi edited a comment on issue #6965:
URL: https://github.com/apache/pulsar/issues/6965#issuecomment-629982830
I checked the UT
`org.apache.pulsar.client.api.SimpleProducerConsumerTest#testPauseAndResume`
```java
log.info("Giving message listener an opportunity to receive me
56 matches
Mail list logo
