kirill-kosenko opened a new issue #10306:
URL: https://github.com/apache/pulsar/issues/10306
Hello
I'm running into an issue with Pulsar Transactions, here are the details:
I'm following the documentation:
```
Transaction txn = pulsarClient
.newTransaction()
.withTransactionTimeout(5, TimeUnit.MINUTES)
.build()
.get();
Message<String> message = sourceConsumer.receive();
sourceConsumer.acknowledgeAsync(message.getMessageId(), txn);
sinkProducer.newMessage(txn).value("sink data").sendAsync();
txn.commit().get();
```
Before commiting the transaction `txn.commit().get()` I kill the app
process.
However after waiting for 5 mins(Transaction timeout) if I restart app and
try to process the same message with commiting the transaction
I get an exception:
```
org.apache.pulsar.client.api.PulsarClientException$TransactionConflictException:
org.apache.pulsar.transaction.common.exception.TransactionConflictException:
[persistent://public/default/test-events-partition-0][test-subscription]
Transaction:(1,1) try to ack message:1307:1 in pending ack status.
```
Did I miss something?
Hope it was clear
--
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 the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
