aio-libs/aiokafka

Vedi su GitHub

asyncio client for kafka

Stelle: 1.4k
Fork: 269
Issue aperte per principianti: 0
Issue indicizzate: 160
Merge medio: 1g 1h
PR unite (30g): 6

Lingua principale: Python
Licenza: Apache-2.0
Ultimo push su GitHub: 10/9/2026
Ultima indicizzazione: 13/9/2026
Guida per i contributori: Guida per i contributori
Codice di condotta: Codice di condotta
Label per principianti: help wanted

Aperta Tutte

160 issue aperte indicizzate

High Incoming request sum on Azure Event Hub Aperta

aio-libs/aiokafka#990 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] Unable connect to node with id: X: [Errno 111]: Connection refused Aperta

question

aio-libs/aiokafka#992 · 1 commento · 2 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] How to get old messages from topics? Aperta

question

aio-libs/aiokafka#998 · 4 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] How to check readiness of kafka to receive msgs from producer? Aperta

question

aio-libs/aiokafka#1002 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
seek_to_committed does not work when committed offset is 0 Aperta

aio-libs/aiokafka#1003 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Unexpected error during batch delivery Aperta

aio-libs/aiokafka#1004 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
IncompatibleBrokerVersion: Kafka broker does not support the 'CreateTopicsRequest_v0' Kafka protocol. Aperta

aio-libs/aiokafka#1008 · 5 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] Restarting `AIOKafkaConsumer` after `AIOKafkaConsumer.stop()` Aperta

question

aio-libs/aiokafka#1010 · 4 commenti · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] How to close connection if Kafka server isn't responding? Aperta

question

aio-libs/aiokafka#1013 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] Is there support to refresh OAuth tokens automatically based on token expiration duration? Aperta

question

aio-libs/aiokafka#1015 · 0 commenti · 2 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Add client.rack configuration option to support consumer fetching from closest replica (KIP-392) Aperta

enhancement

aio-libs/aiokafka#1016 · 2 commenti · 7 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] idempotent producer and OutOfOrderSequenceNumber problem Aperta

question

aio-libs/aiokafka#1017 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Can't Recover From NotLeaderForPartitionError Aperta

aio-libs/aiokafka#1018 · 0 commenti · 4 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Unclosed AIOKafkaConnection that does not cause the consumer to crash Aperta

aio-libs/aiokafka#1019 · 1 commento · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026
Connection errors are spamming Aperta

aio-libs/aiokafka#1020 · 1 commento · 4 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Update `aiokafka` library to support higher client versions > 3 Aperta

enhancement

aio-libs/aiokafka#1023 · 9 commenti · 2 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
A large and controversial proposal: replace protocol implementation with kio Aperta

enhancement

aio-libs/aiokafka#1027 · 3 commenti · 3 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Severe performance degradation after migrating to cramjam LZ4 Aperta

aio-libs/aiokafka#1028 · 11 commenti · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026
Losing Messages Between Producer and Consumer Aperta

aio-libs/aiokafka#1031 · 6 commenti · 2 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Long running consumer stop receiving messages and it's state is not closed Aperta

aio-libs/aiokafka#1037 · 8 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Closing of connection from server don't caught for uvloop Aperta

aio-libs/aiokafka#1038 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Producer.send_and_wait() hangs up forever if `sender_task` is cancelled Aperta

aio-libs/aiokafka#1039 · 0 commenti · 4 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] Is there a way to monitor the heartbeat state? Aperta

question

aio-libs/aiokafka#1040 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Admin client: list offsets per topic/partition Aperta

enhancement

aio-libs/aiokafka#1045 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Producers hangs while stopping in frozen datetime context Aperta

aio-libs/aiokafka#1060 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] How to detect connection issues with a consumer? Aperta

question

aio-libs/aiokafka#1073 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Consumer/channel does not reauthenticate based on SaslAuthenticateResponse Aperta

aio-libs/aiokafka#1080 · 1 commento · 4 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] extremly high Fetch Rate Aperta

question

aio-libs/aiokafka#1081 · 2 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
How does partition reassignment occur instantly when on_partitions_revoked suggests committing offsets? Aperta

question

aio-libs/aiokafka#1084 · 0 commenti · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] Support for Apache Kafka 4.0 Aperta

question

aio-libs/aiokafka#1085 · 14 commenti · 6 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] Why is passing the loop to Consumer and Producer deprecated? Aperta

question

aio-libs/aiokafka#1086 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Support OffsetRequest_v2 Aperta

enhancement

aio-libs/aiokafka#1087 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[KIP 932] Share Groups Support Aperta

enhancement

aio-libs/aiokafka#1089 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Transactional Example not working Aperta

aio-libs/aiokafka#1091 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
StaleLeaderEpochCodeError renamed/removed, error code 13 is NetworkExceptionError Aperta

aio-libs/aiokafka#1093 · 2 commenti · 5 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Not compatible with kafka-python 2.0.4 Aperta

aio-libs/aiokafka#1094 · 3 commenti · 3 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
UnknownTopicOrPartitionError cause infinite loop inside aiokafka.consumer.group_coordinator GroupCoordinator class, commit_offsets function Aperta

aio-libs/aiokafka#1095 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] In AIOKafkaProducer.__init__ is acks=-1 exactly the same as acks="all" ? Aperta

question

aio-libs/aiokafka#1096 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
AIOKafkaConsumer throws corrupted message exceptions on big-endian OS Aperta

aio-libs/aiokafka#1097 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
KeyError when trying to commit offsets using Transactional Producer Aperta

aio-libs/aiokafka#1098 · 2 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
[QUESTION] How to remove warning:"aiokafka sending username and password in the clear" Aperta

question

aio-libs/aiokafka#1099 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
`AIOKafkaProducer` appears to hang forever if Kafka is down for `send_and_wait` and `stop()` Aperta

aio-libs/aiokafka#1101 · 2 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
If consumer isn't started, `getmany()` fails with `AttributeError` Aperta

aio-libs/aiokafka#1102 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
UnknownError while consuming from a zstd-compressed topic - broker returns error code 76 (UNSUPPORTED_COMPRESSION_TYPE) Aperta

aio-libs/aiokafka#1112 · 0 commenti · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026
Closed connections are not refreshed in client.py _send Aperta

aio-libs/aiokafka#1118 · 1 commento · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Dependency on deprecated async-timeout Aperta

enhancement

aio-libs/aiokafka#1123 · 3 commenti · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026
`test_read_write_serde_v2`[zstd] fails with cramjam 2.11.0 Aperta

aio-libs/aiokafka#1124 · 0 commenti · 0 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Support for CooperativeStickyAssignor Aperta

enhancement

aio-libs/aiokafka#1126 · 2 commenti · 8 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
‎AIOKafkaProducer.send‎ shuffles partitions when running in PyPy environments Aperta

aio-libs/aiokafka#1127 · 1 commento · 2 reazioni · 0 assegnatari · Indicizzata il 13/9/2026
Unclosed consumer and producer warnings when using AsyncContextManager interface Aperta

aio-libs/aiokafka#1130 · 0 commenti · 1 reazione · 0 assegnatari · Indicizzata il 13/9/2026

aio-libs/aiokafka

Ricevi le nuove issue nella tua casella