Skip to content

Pull requests: aio-libs/aiokafka

New pull request New
34 Open 702 Closed
34 Open 702 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Add lightweight producer metrics collector
#1171 opened Jul 11, 2026 by GlebShipilov Contributor Loading…
4 tasks done
1
9
Fix spelling typos in source comments and documentation
#1170 opened Jul 8, 2026 by maxtaran2010 Loading…
1
Make key-based partition selection deterministic
#1169 opened Jul 4, 2026 by arpitjain099 Loading…
3 of 4 tasks
1
Don't send more than one JoinGroup request when more than one Assignors are specified
#1168 opened Jun 13, 2026 by ilolis Loading…
4 tasks done
fix: add full jitter to Fetcher retry backoff (thundering herd on leader election)
#1167 opened Jun 4, 2026 by KaustubhUp025 • Draft
2 tasks
1
feat: use zstd from stdlib on python >= 3.14
#1161 opened May 3, 2026 by sk- Loading…
3 of 4 tasks
1
1
Bump pytest from 9.0.2 to 9.0.3 in the pip group across 1 directory dependencies Pull requests that update a dependency file python Pull requests that update python code
#1157 opened Apr 14, 2026 by dependabot Bot Loading…
1
perf: optimize MessageBatch.wait_drain() to avoid asyncio.wait overhead
#1144 opened Dec 29, 2025 by gloryfromca Loading…
4 tasks
2
fix: make AIOKafkaProducer.start() idempotent to prevent busy loop
#1143 opened Dec 29, 2025 by gloryfromca Loading…
4 tasks
Avoid unclosed consumer and producer warnings when using AsyncContextManager interface
#1131 opened Oct 24, 2025 by calgray Loading…
4 tasks done
1
Make AIOKafkaAdminClient an asynchronous context manager
#1129 opened Oct 21, 2025 by PeterJCLaw Loading…
3 of 4 tasks
1
Include "start" in the try/finally in docs
#1128 opened Oct 2, 2025 by vmaurin Contributor Loading…
4 tasks done
1
1
Use fastest compression level
#1121 opened Aug 15, 2025 by dolfinus Loading…
1 of 4 tasks
1
1
feat(fetch): add full Fetch v10 support
#1111 opened May 28, 2025 by mesteruh Loading…
3 of 4 tasks
712.bugfix: wait when metadata update
#1108 opened May 13, 2025 by khab-el Loading…
4 tasks done
1
Add support for rack id in the consumer
#1107 opened May 12, 2025 by vbhavsar Loading…
3 of 4 tasks
1
2
KIP-368: Allow SASL Connections to Periodically Re-Authenticate
#1105 opened May 6, 2025 by kprzybyla Loading…
4 tasks done
2
9
Assert if the consumer has started before performing an operation
#1104 opened Apr 17, 2025 by kPsarakis Loading…
1 of 4 tasks
1
Add concurrent consumption example to docs
#1092 opened Feb 16, 2025 by Arseniy-Popov Loading…
1 of 4 tasks
Add round robin partitioner
#1088 opened Jan 27, 2025 by Arseniy-Popov Loading…
2 of 4 tasks
Add stub typing for clients
#1075 opened Nov 15, 2024 by jackgene Contributor Loading…
4 tasks
1
10
Added type annotation to public classes.
#1074 opened Nov 15, 2024 by jackgene Contributor • Draft
4 tasks
1
4
fix: check writer is closing in AIOKafkaConnection.send
#1044 opened Aug 19, 2024 by dimastbk Contributor Loading…
1 of 4 tasks
1
6
Add type hints to message_accumulator
#1026 opened Jul 2, 2024 by antonagestam Loading…
1 of 4 tasks
add typing to aiokafka/cluster.py
#1024 opened Jul 2, 2024 by dimastbk Contributor • Draft
4 tasks
9
ProTip! Adding no:label will show everything without a label.