Skip to content

Check listener transactional property#1471

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

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

Conversation

@rbleuse
Copy link
Copy Markdown

@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 <chris.bono@gmail.com>
Signed-off-by: Rémi Bleuse <remi.bleuse@gmail.com>
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 <chris.bono@gmail.com>
Signed-off-by: Rémi Bleuse <remi.bleuse@gmail.com>
Signed-off-by: Rémi Bleuse <remi.bleuse@gmail.com>
Signed-off-by: Rémi Bleuse <remi.bleuse@gmail.com>
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

2 participants