aiokafka icon indicating copy to clipboard operation
aiokafka copied to clipboard

[QUESTION] How does transaction_timeout_ms work?

Open InterferencePattern opened this issue 2 years ago • 0 comments

I don't see an explanation of TransactionManager's transaction_timeout_ms` in the docs. Is that value a timeout for the context? For example, if you use

async for msg in consumer:
    async with producer.transaction():
        ...

will it automatically close the context without a transaction? If so, will it retry the same message/offset?

InterferencePattern avatar Feb 17 '23 19:02 InterferencePattern