aio-libs/aiokafka

在 GitHub 查看

asyncio client for kafka

星标: 1.4k
派生: 269
开放的新手 issue: 0
已索引 issue: 160
平均合并: 1 天 1 小时
30 天内合并 PR: 6

主要语言: Python
许可证: Apache-2.0
最近 GitHub push: 2026年9月10日
最近索引: 2026年9月13日
贡献指南: 贡献指南
行为准则: 行为准则
新手标签: help wanted

未关闭全部

目前已索引 160 个未关闭的 Issue

High Incoming request sum on Azure Event Hub 未关闭

aio-libs/aiokafka#990 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] Unable connect to node with id: X: [Errno 111]: Connection refused 未关闭

question

aio-libs/aiokafka#992 · 1 条评论 · 2 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] How to get old messages from topics? 未关闭

question

aio-libs/aiokafka#998 · 4 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] How to check readiness of kafka to receive msgs from producer? 未关闭

question

aio-libs/aiokafka#1002 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
seek_to_committed does not work when committed offset is 0 未关闭

aio-libs/aiokafka#1003 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Unexpected error during batch delivery 未关闭

aio-libs/aiokafka#1004 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
IncompatibleBrokerVersion: Kafka broker does not support the 'CreateTopicsRequest_v0' Kafka protocol. 未关闭

aio-libs/aiokafka#1008 · 5 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] Restarting `AIOKafkaConsumer` after `AIOKafkaConsumer.stop()` 未关闭

question

aio-libs/aiokafka#1010 · 4 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] How to close connection if Kafka server isn't responding? 未关闭

question

aio-libs/aiokafka#1013 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] Is there support to refresh OAuth tokens automatically based on token expiration duration? 未关闭

question

aio-libs/aiokafka#1015 · 0 条评论 · 2 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Add client.rack configuration option to support consumer fetching from closest replica (KIP-392) 未关闭

enhancement

aio-libs/aiokafka#1016 · 2 条评论 · 7 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] idempotent producer and OutOfOrderSequenceNumber problem 未关闭

question

aio-libs/aiokafka#1017 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Can't Recover From NotLeaderForPartitionError 未关闭

aio-libs/aiokafka#1018 · 0 条评论 · 4 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Unclosed AIOKafkaConnection that does not cause the consumer to crash 未关闭

aio-libs/aiokafka#1019 · 1 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Connection errors are spamming 未关闭

aio-libs/aiokafka#1020 · 1 条评论 · 4 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Update `aiokafka` library to support higher client versions > 3 未关闭

enhancement

aio-libs/aiokafka#1023 · 9 条评论 · 2 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
A large and controversial proposal: replace protocol implementation with kio 未关闭

enhancement

aio-libs/aiokafka#1027 · 3 条评论 · 3 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Severe performance degradation after migrating to cramjam LZ4 未关闭

aio-libs/aiokafka#1028 · 11 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Losing Messages Between Producer and Consumer 未关闭

aio-libs/aiokafka#1031 · 6 条评论 · 2 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Long running consumer stop receiving messages and it's state is not closed 未关闭

aio-libs/aiokafka#1037 · 8 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Closing of connection from server don't caught for uvloop 未关闭

aio-libs/aiokafka#1038 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Producer.send_and_wait() hangs up forever if `sender_task` is cancelled 未关闭

aio-libs/aiokafka#1039 · 0 条评论 · 4 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] Is there a way to monitor the heartbeat state? 未关闭

question

aio-libs/aiokafka#1040 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Admin client: list offsets per topic/partition 未关闭

enhancement

aio-libs/aiokafka#1045 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Producers hangs while stopping in frozen datetime context 未关闭

aio-libs/aiokafka#1060 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] How to detect connection issues with a consumer? 未关闭

question

aio-libs/aiokafka#1073 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Consumer/channel does not reauthenticate based on SaslAuthenticateResponse 未关闭

aio-libs/aiokafka#1080 · 1 条评论 · 4 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] extremly high Fetch Rate 未关闭

question

aio-libs/aiokafka#1081 · 2 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
How does partition reassignment occur instantly when on_partitions_revoked suggests committing offsets? 未关闭

question

aio-libs/aiokafka#1084 · 0 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] Support for Apache Kafka 4.0 未关闭

question

aio-libs/aiokafka#1085 · 14 条评论 · 6 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] Why is passing the loop to Consumer and Producer deprecated? 未关闭

question

aio-libs/aiokafka#1086 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Support OffsetRequest_v2 未关闭

enhancement

aio-libs/aiokafka#1087 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[KIP 932] Share Groups Support 未关闭

enhancement

aio-libs/aiokafka#1089 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Transactional Example not working 未关闭

aio-libs/aiokafka#1091 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
StaleLeaderEpochCodeError renamed/removed, error code 13 is NetworkExceptionError 未关闭

aio-libs/aiokafka#1093 · 2 条评论 · 5 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Not compatible with kafka-python 2.0.4 未关闭

aio-libs/aiokafka#1094 · 3 条评论 · 3 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
UnknownTopicOrPartitionError cause infinite loop inside aiokafka.consumer.group_coordinator GroupCoordinator class, commit_offsets function 未关闭

aio-libs/aiokafka#1095 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] In AIOKafkaProducer.__init__ is acks=-1 exactly the same as acks="all" ? 未关闭

question

aio-libs/aiokafka#1096 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
AIOKafkaConsumer throws corrupted message exceptions on big-endian OS 未关闭

aio-libs/aiokafka#1097 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
KeyError when trying to commit offsets using Transactional Producer 未关闭

aio-libs/aiokafka#1098 · 2 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
[QUESTION] How to remove warning:"aiokafka sending username and password in the clear" 未关闭

question

aio-libs/aiokafka#1099 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
`AIOKafkaProducer` appears to hang forever if Kafka is down for `send_and_wait` and `stop()` 未关闭

aio-libs/aiokafka#1101 · 2 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
If consumer isn't started, `getmany()` fails with `AttributeError` 未关闭

aio-libs/aiokafka#1102 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
UnknownError while consuming from a zstd-compressed topic - broker returns error code 76 (UNSUPPORTED_COMPRESSION_TYPE) 未关闭

aio-libs/aiokafka#1112 · 0 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Closed connections are not refreshed in client.py _send 未关闭

aio-libs/aiokafka#1118 · 1 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Dependency on deprecated async-timeout 未关闭

enhancement

aio-libs/aiokafka#1123 · 3 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
`test_read_write_serde_v2`[zstd] fails with cramjam 2.11.0 未关闭

aio-libs/aiokafka#1124 · 0 条评论 · 0 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Support for CooperativeStickyAssignor 未关闭

enhancement

aio-libs/aiokafka#1126 · 2 条评论 · 8 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
‎AIOKafkaProducer.send‎ shuffles partitions when running in PyPy environments 未关闭

aio-libs/aiokafka#1127 · 1 条评论 · 2 个 reaction · 已指派 0 人 · 索引于 2026年9月13日
Unclosed consumer and producer warnings when using AsyncContextManager interface 未关闭

aio-libs/aiokafka#1130 · 0 条评论 · 1 个 reaction · 已指派 0 人 · 索引于 2026年9月13日

aio-libs/aiokafka

把新 issue 发到你的邮箱