aiokafka
aiokafka copied to clipboard
[QUESTION] How does transaction_timeout_ms work?
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?