aiokafka

aiokafka copied to clipboard

On application startup, if the recovery process is unable to fetch the highwater offsets for the changelog topics, it swallows the exception and returns -1 as the offset. The correct...

patkivikram

in sender.py ``` except Exception: # pragma: no cover log.error("Unexpected error in sender routine", exc_info=True) if self._on_irrecoverable_error: res = self._on_irrecoverable_error(exc) if asyncio.iscoroutine(res): # callback can be async def yield from...

patkivikram

I'm calling aiokafka directly to work around limitations of the faust abstractions. I've run into the following stack trace (output thanks to PYTHONASYNCIODEBUG=1). It seems to happen after I've consumed...

TomGoBravo