Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Failed to add producer to topic（C language Client） #8124

Closed
futeng opened this issue Sep 24, 2020 · 2 comments · Fixed by #8191
Closed

Failed to add producer to topic（C language Client） #8124

futeng opened this issue Sep 24, 2020 · 2 comments · Fixed by #8191
Labels
help wanted type/bug The PR fixed a bug or issue reported a bug

Comments

@futeng
Copy link
Contributor

futeng commented Sep 24, 2020

Describe the bug
Same issue like #5535, but in C language Client.
Also see the track issue: #5606

broker log

07:25:01.322 [ForkJoinPool.commonPool-worker-60] INFO  org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] persistent://tenantname/ns_name/partition_name-15 configured with schema false
07:25:01.323 [ForkJoinPool.commonPool-worker-60] ERROR org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] Failed to add producer to topic persistent://tenantname/ns_name/partition_name-15: Producer with name 'producer_name-254-20972' is already connected to topic
07:25:01.323 [ForkJoinPool.commonPool-worker-60] INFO  org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] persistent://tenantname/ns_name/partition_name-11 configured with schema false
07:25:01.323 [ForkJoinPool.commonPool-worker-60] ERROR org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] Failed to add producer to topic persistent://tenantname/ns_name/partition_name-11: Producer with name 'producer_name-254-20971' is already connected to topic
07:25:01.323 [ForkJoinPool.commonPool-worker-60] INFO  org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] persistent://tenantname/ns_name/partition_name-25 configured with schema false
07:25:01.323 [ForkJoinPool.commonPool-worker-60] ERROR org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] Failed to add producer to topic persistent://tenantname/ns_name/partition_name-25: Producer with name 'producer_name-254-20974' is already connected to topic
07:25:01.323 [ForkJoinPool.commonPool-worker-60] INFO  org.apache.pulsar.broker.service.ServerCnx - [/IP:51820] persistent://tenantname/ns_name/partition_name-3 configured with schema false

To Reproduce

Server versions：

  • JDK: 1.8.0_192
  • Apache Pulsar: 2.5.0
  • Zookeeper：3.6.1

Client ：

$ rpm -qa | grep apache
apache-pulsar-client-debuginfo-2.6.0-1.x86_64
apache-commons-lang-2.6-15.el7.noarch
apache-pulsar-client-2.6.0-1.x86_64
apache-pulsar-client-devel-2.6.0-1.x86_64
apache-commons-io-2.4-12.el7.noarch
apache-commons-logging-1.1.2-7.el7.noarch
@futeng futeng added the type/bug The PR fixed a bug or issue reported a bug label Sep 24, 2020
@sijie sijie mentioned this issue Sep 24, 2020
Closed
@jiazhai
Copy link
Member

jiazhai commented Sep 28, 2020

looks like same issue of #5535, we should port the client changes of #5571 from java to cpp client.
@futeng Would you like to have a for this issue?

@hangc0276
Copy link
Contributor

I will try to fix it.

@hangc0276 hangc0276 mentioned this issue Oct 3, 2020
Merged
sijie pushed a commit that referenced this issue Oct 5, 2020
@hangc0276
add epoch for C++ client HandleBase to handle create producer timeout (…
8572ffb 
…#8191)

Fix #8124 

### Changes
Related to `PR-5571`, I add epoch on `HandleBase` for C++ Client.
Due to C++ client not expose handler interface to producer client, i can't add epoch test in the test case. I doubt whether to expose those interfaces to get handler instance and epoch just for test case.

Please take a look and give me some ideas. @sijie @jiazhai @codelipenghui
wolfstudy pushed a commit that referenced this issue Oct 30, 2020
@hangc0276 @wolfstudy
add epoch for C++ client HandleBase to handle create producer timeout (…
7ccb0e1 
…#8191)

Fix #8124 

### Changes
Related to `PR-5571`, I add epoch on `HandleBase` for C++ Client.
Due to C++ client not expose handler interface to producer client, i can't add epoch test in the test case. I doubt whether to expose those interfaces to get handler instance and epoch just for test case.

Please take a look and give me some ideas. @sijie @jiazhai @codelipenghui 

(cherry picked from commit 8572ffb)
huangdx0726 pushed a commit to huangdx0726/pulsar that referenced this issue Nov 13, 2020
@hangc0276 @huangdx0726
add epoch for C++ client HandleBase to handle create producer timeout (…
c86d8cf 
…apache#8191)

Fix apache#8124 

### Changes
Related to `PR-5571`, I add epoch on `HandleBase` for C++ Client.
Due to C++ client not expose handler interface to producer client, i can't add epoch test in the test case. I doubt whether to expose those interfaces to get handler instance and epoch just for test case.

Please take a look and give me some ideas. @sijie @jiazhai @codelipenghui
merlimat pushed a commit to merlimat/pulsar that referenced this issue Dec 19, 2020
@hangc0276 @merlimat
add epoch for C++ client HandleBase to handle create producer timeout (…
8430423 
…apache#8191)

Fix apache#8124 

### Changes
Related to `PR-5571`, I add epoch on `HandleBase` for C++ Client.
Due to C++ client not expose handler interface to producer client, i can't add epoch test in the test case. I doubt whether to expose those interfaces to get handler instance and epoch just for test case.

Please take a look and give me some ideas. @sijie @jiazhai @codelipenghui
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
help wanted type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

add epoch for C++ client HandleBase to handle create producer timeout hangc0276/pulsar
3 participants
@futeng @hangc0276 @jiazhai