Skip to content

Check listener transactional property#1471

Closed
rbleuse wants to merge 4 commits intospring-projects:mainfrom
rbleuse:gh-1438
Closed

Check listener transactional property#1471
rbleuse wants to merge 4 commits intospring-projects:mainfrom
rbleuse:gh-1438

Conversation

@rbleuse
Copy link
Copy Markdown
Contributor

@rbleuse rbleuse commented Apr 9, 2026

After fix :

2026-04-09T10:09:47.490+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [r-client-io-1-3] p.c.i.t.TransactionCoordinatorClientImpl : Transaction meta store assign partition is 1.
2026-04-09T10:10:10.221+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [    Test worker] o.s.p.c.MethodPulsarListenerEndpoint     : Listener w/ id [org.springframework.Pulsar.PulsarListenerEndpointContainer#0] requested no transactions
2026-04-09T10:10:10.620+09:00  INFO 42252 --- [spring-pulsar-transaction] [r-client-io-1-3] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic][message] Subscribing to topic on cnx [id: 0x1a215b96, L:/127.0.0.1:62140 - R:localhost/127.0.0.1:37783], consumerId 0
2026-04-09T10:10:10.974+09:00  INFO 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic][message] Subscribed to topic on localhost/127.0.0.1:37783 -- consumer: 0
2026-04-09T10:10:10.975+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic] Sending permit-cmd to broker with available permits = 1000
2026-04-09T10:10:10.975+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic] [message] Adding 1000 additional permits
2026-04-09T10:10:10.979+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : Consumer 0 sent 1000 permits to broker
2026-04-09T10:10:11.888+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic][message] Received message: 6:0
2026-04-09T10:10:11.945+09:00  INFO 42252 --- [spring-pulsar-transaction] [ntainer#0-0-C-1] c.g.r.s.listener.MessageListener         : Received message ID 6:0:-1, with txn ID null and txn state null
2026-04-09T10:10:12.094+09:00 DEBUG 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic][message] Received message: 6:1
2026-04-09T10:10:12.159+09:00  INFO 42252 --- [spring-pulsar-transaction] [ntainer#0-0-C-1] c.g.r.s.listener.MessageListener         : Received message ID 6:1:-1, with txn ID null and txn state null
2026-04-09T10:10:12.263+09:00  INFO 42252 --- [spring-pulsar-transaction] [r-client-io-1-5] o.a.pulsar.client.impl.ConsumerImpl      : [persistent://public/default/test-topic] [message] Closed consumer

fixes #1438

onobc and others added 4 commits April 9, 2026 10:29
Signed-off-by: onobc <[email protected]>
Signed-off-by: Rémi Bleuse <[email protected]>
Since apache/pulsar#25238, Pulsar standalone mode advertises the container's FQDN
(the container ID) instead of localhost. The Pulsar client reconnects to the
advertised address during service discovery, but is unable to reach the FQDN.

Setting advertisedAddress to localhost fixes the mismatch.

Resolves spring-projects#1470

Signed-off-by: onobc <[email protected]>
Signed-off-by: Rémi Bleuse <[email protected]>
Signed-off-by: Rémi Bleuse <[email protected]>
Signed-off-by: Rémi Bleuse <[email protected]>
@onobc
Copy link
Copy Markdown
Contributor

onobc commented Apr 11, 2026

Closing in favor of #1475 .

@sobychacko
Copy link
Copy Markdown
Collaborator

I just merged #1475. As @onobc noted above, we are closing this PR. @rbleuse Thanks a lot for the PR!

@sobychacko sobychacko closed this Apr 13, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Non-transactional listener when transaction property is enabled

3 participants