aio-libs/aiokafka

Auf GitHub ansehen

asyncio client for kafka

Sterne: 1.4k
Forks: 269
Offene Anfänger-Issues: 0
Indexierte Issues: 160
Ø Merge: 1 T. 1 Std.
Gemergte PRs (30 T.): 6

Vorherrschende Sprache: Python
Lizenz: Apache-2.0
Letzter GitHub-Push: 10.9.2026
Zuletzt indexiert: 13.9.2026
Beitragsleitfaden: Beitragsleitfaden
Verhaltenskodex: Verhaltenskodex
Anfänger-Labels: help wanted

Offen Alle

Bisher 160 offene Issues indexiert

High Incoming request sum on Azure Event Hub Offen

aio-libs/aiokafka#990 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] Unable connect to node with id: X: [Errno 111]: Connection refused Offen

question

aio-libs/aiokafka#992 · 1 Kommentar · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] How to get old messages from topics? Offen

question

aio-libs/aiokafka#998 · 4 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] How to check readiness of kafka to receive msgs from producer? Offen

question

aio-libs/aiokafka#1002 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
seek_to_committed does not work when committed offset is 0 Offen

aio-libs/aiokafka#1003 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Unexpected error during batch delivery Offen

aio-libs/aiokafka#1004 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
IncompatibleBrokerVersion: Kafka broker does not support the 'CreateTopicsRequest_v0' Kafka protocol. Offen

aio-libs/aiokafka#1008 · 5 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] Restarting `AIOKafkaConsumer` after `AIOKafkaConsumer.stop()` Offen

question

aio-libs/aiokafka#1010 · 4 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] How to close connection if Kafka server isn't responding? Offen

question

aio-libs/aiokafka#1013 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] Is there support to refresh OAuth tokens automatically based on token expiration duration? Offen

question

aio-libs/aiokafka#1015 · 0 Kommentare · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Add client.rack configuration option to support consumer fetching from closest replica (KIP-392) Offen

enhancement

aio-libs/aiokafka#1016 · 2 Kommentare · 7 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] idempotent producer and OutOfOrderSequenceNumber problem Offen

question

aio-libs/aiokafka#1017 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Can't Recover From NotLeaderForPartitionError Offen

aio-libs/aiokafka#1018 · 0 Kommentare · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Unclosed AIOKafkaConnection that does not cause the consumer to crash Offen

aio-libs/aiokafka#1019 · 1 Kommentar · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026
Connection errors are spamming Offen

aio-libs/aiokafka#1020 · 1 Kommentar · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Update `aiokafka` library to support higher client versions > 3 Offen

enhancement

aio-libs/aiokafka#1023 · 9 Kommentare · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
A large and controversial proposal: replace protocol implementation with kio Offen

enhancement

aio-libs/aiokafka#1027 · 3 Kommentare · 3 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Severe performance degradation after migrating to cramjam LZ4 Offen

aio-libs/aiokafka#1028 · 11 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026
Losing Messages Between Producer and Consumer Offen

aio-libs/aiokafka#1031 · 6 Kommentare · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Long running consumer stop receiving messages and it's state is not closed Offen

aio-libs/aiokafka#1037 · 8 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Closing of connection from server don't caught for uvloop Offen

aio-libs/aiokafka#1038 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Producer.send_and_wait() hangs up forever if `sender_task` is cancelled Offen

aio-libs/aiokafka#1039 · 0 Kommentare · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] Is there a way to monitor the heartbeat state? Offen

question

aio-libs/aiokafka#1040 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Admin client: list offsets per topic/partition Offen

enhancement

aio-libs/aiokafka#1045 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Producers hangs while stopping in frozen datetime context Offen

aio-libs/aiokafka#1060 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] How to detect connection issues with a consumer? Offen

question

aio-libs/aiokafka#1073 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Consumer/channel does not reauthenticate based on SaslAuthenticateResponse Offen

aio-libs/aiokafka#1080 · 1 Kommentar · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] extremly high Fetch Rate Offen

question

aio-libs/aiokafka#1081 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
How does partition reassignment occur instantly when on_partitions_revoked suggests committing offsets? Offen

question

aio-libs/aiokafka#1084 · 0 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] Support for Apache Kafka 4.0 Offen

question

aio-libs/aiokafka#1085 · 14 Kommentare · 6 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] Why is passing the loop to Consumer and Producer deprecated? Offen

question

aio-libs/aiokafka#1086 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Support OffsetRequest_v2 Offen

enhancement

aio-libs/aiokafka#1087 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[KIP 932] Share Groups Support Offen

enhancement

aio-libs/aiokafka#1089 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Transactional Example not working Offen

aio-libs/aiokafka#1091 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
StaleLeaderEpochCodeError renamed/removed, error code 13 is NetworkExceptionError Offen

aio-libs/aiokafka#1093 · 2 Kommentare · 5 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Not compatible with kafka-python 2.0.4 Offen

aio-libs/aiokafka#1094 · 3 Kommentare · 3 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
UnknownTopicOrPartitionError cause infinite loop inside aiokafka.consumer.group_coordinator GroupCoordinator class, commit_offsets function Offen

aio-libs/aiokafka#1095 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] In AIOKafkaProducer.__init__ is acks=-1 exactly the same as acks="all" ? Offen

question

aio-libs/aiokafka#1096 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
AIOKafkaConsumer throws corrupted message exceptions on big-endian OS Offen

aio-libs/aiokafka#1097 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
KeyError when trying to commit offsets using Transactional Producer Offen

aio-libs/aiokafka#1098 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
[QUESTION] How to remove warning:"aiokafka sending username and password in the clear" Offen

question

aio-libs/aiokafka#1099 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
`AIOKafkaProducer` appears to hang forever if Kafka is down for `send_and_wait` and `stop()` Offen

aio-libs/aiokafka#1101 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
If consumer isn't started, `getmany()` fails with `AttributeError` Offen

aio-libs/aiokafka#1102 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
UnknownError while consuming from a zstd-compressed topic - broker returns error code 76 (UNSUPPORTED_COMPRESSION_TYPE) Offen

aio-libs/aiokafka#1112 · 0 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026
Closed connections are not refreshed in client.py _send Offen

aio-libs/aiokafka#1118 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Dependency on deprecated async-timeout Offen

enhancement

aio-libs/aiokafka#1123 · 3 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026
`test_read_write_serde_v2`[zstd] fails with cramjam 2.11.0 Offen

aio-libs/aiokafka#1124 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Support for CooperativeStickyAssignor Offen

enhancement

aio-libs/aiokafka#1126 · 2 Kommentare · 8 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
‎AIOKafkaProducer.send‎ shuffles partitions when running in PyPy environments Offen

aio-libs/aiokafka#1127 · 1 Kommentar · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 13.9.2026
Unclosed consumer and producer warnings when using AsyncContextManager interface Offen

aio-libs/aiokafka#1130 · 0 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 13.9.2026

aio-libs/aiokafka

Neue Issues direkt in Ihr Postfach