aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
### Changes Adds type annotation to public classes, and `py.typed` so that client code can type check against this library. Fixes https://github.com/aio-libs/aiokafka/issues/980 (kind of) Note that the issue in question...
**Describe the bug** When a consumer's connection outlives its SASL authentication (in this case an OAuth token), then consumer will fail to fetch new records because the broker no longer...
**Describe the bug** If a consumer is created but not started and the `genmany()` method is called, an AttributeError results. **Expected behaviour** A user friendly error that explains the problem...
I am using plaintext transmission of usernames and passwords in an intranet security environment, but aiokafka keeps issuing such warnings. I want to safely suppress these warnings. How should I...
**Describe the bug** When trying to commit offsets with a transactional producer doing ` await producer.send_offsets_to_transaction(offsets, group_id)` there is a sort of race condition where it seems that two background...
**Describe the bug** Trying to consume messages with the AIOKafkaConsumer leads to corrupted message exceptions. This error happens consistently and prevents any messages from being processed. Messages are valid and...
**Describe the bug** kafka-python has changed/renamed error code 13 from StaleLeaderEpochCodeError to NetworkExceptionError in kafka-python 2.0.4 - https://github.com/dpkp/kafka-python/compare/2.0.3...2.0.4#diff-f5c6e5f20fe82d1a9b3449920cb1f7cf6bbbd448bd516f25c4b414ed2ae20f98. This matches kafka docs for protocol errors - https://kafka.apache.org/11/protocol.html#protocol_error_codes **Expected behaviour** aoikafka...
If it is, maybe it should be documented that passing -1 is also valid and means the same as "all" ? Current documentation says that only "all", 0 and 1...
Hey, the version 0.8.1 of aiokafka does not seem to be compatible with the latest kafka-python version (2.0.4).  The StaleLeaderEpochCodeError seems to be removed in version 2.0.4 released on...
**Describe the bug** I am using async consumer with subscribe by pattern. I need to support working against topics which may added and removed over time. When we remove a...
