aio-libs / aio-libs/aiokafka

[QUESTION] How does transaction_timeout_ms work?

未關閉
#877 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
question
主要語言
Python
星號
1.4k
分支
269
平均合併
1 天 1 小時
30 天內合併 PR
6

描述

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?

貢獻指南

開啟貢獻指南

評估

這個 Issue 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。