Nik

Implement KIP-345 in aiokafka (rebase of #682)

4

### Changes Fixes #680 This is a rebase of https://github.com/aio-libs/aiokafka/pull/682 -- see https://github.com/aio-libs/aiokafka/pull/682#issuecomment-1070337629 ### Checklist - [ ] I think the code is well written - [ ] Unit tests...

Calling `getmany` seems to [suggest it updates consumed offsets at the same time](https://github.com/aio-libs/aiokafka/blob/081087d1c92e2bf6ee3660843f641bfb4f3fd754/aiokafka/consumer/fetcher.py#L1043-L1045). There are warnings in various places around manual commits, and suggestions that committing after each message is...

Differentiate between missing values and null values

4

I'm trying to do a search like: ```python from jmespath import search data = { "grid": [ {"col1": "a", "col2": None}, {"col1": "b", "col2": None}, {"col1": "c", "col2": "x"}, {"col1":...

[QUESTION] what's the recommended way to stop a consumer without auto-committing?

3

[consumer.stop](https://aiokafka.readthedocs.io/en/stable/api.html#aiokafka.AIOKafkaConsumer.stop) will > Commit last consumed message if autocommit enabled For a consumer with `enable.auto.commit=True`, I'd like to be able to shutdown without committing in order maintain better control over...