aio-libs / aio-libs/aiokafka

[QUESTION] How does transaction_timeout_ms work?

Aberta
#877 0 comentários 0 reações 0 responsáveis Ver no GitHub
question
Linguagem predominante
Python
Estrelas
1.4k
Forks
269
Merge médio
1d 1h
PRs com merge (30d)
6

Descrição

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?

Guia de contribuição

Abrir o guia de contribuição

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.