Skip to content

Pull requests: dpkp/kafka-python

New pull request New
26 Open 985 Closed
26 Open 985 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Always log broker errors in producer.send
#2478 opened Feb 13, 2025 by dpkp • Draft
added group.instance.id to consumer group
#2449 opened Oct 22, 2024 by TeisNP Loading…
1
feat AdminClient: support delete_records admin-client
#2359 opened Mar 19, 2023 by alfaix Loading…
1
KIP-345 Static membership implementation consumer network protocol
#2333 opened Oct 23, 2022 by KazakovDenis Loading…
Add zstd support on legacy record and ensure no variable is referred before definition
#2321 opened Aug 5, 2022 by ax-ale Loading…
Dynamic FindCoordinator selection
#2309 opened Mar 21, 2022 by degagne Loading…
Feat: FNV1a 32-Bit Partitioner enhancement needs investigation
#2300 opened Jan 27, 2022 by kemalty Loading…
4
Fix crc32c's __main__ for Python 3 network protocol
#2298 opened Jan 25, 2022 by Jongy Loading…
5
Support custom SASL mechanisms
#2256 opened Aug 20, 2021 by mattoberle Loading…
Support AWS_MSK_IAM authentication
#2255 opened Aug 18, 2021 by mattoberle Loading…
2 of 4 tasks
36
Implemented the return type of the send function;
#2231 opened May 13, 2021 by JGabrielGruber Loading…
5
feat: Add SSPI (Kerberos for Windows) authentication mechanism network protocol
#2219 opened Mar 30, 2021 by manuco Loading…
2
Flush before close
#2213 opened Mar 17, 2021 by moshez Loading…
Admin - Implement perform leader election admin-client
#2186 opened Jan 2, 2021 by ygalblum Loading…
4
Support connections through SOCKS5 proxies
#2169 opened Nov 16, 2020 by hnousiainen Loading…
1
add .editorconfig file enhancement
#2138 opened Oct 10, 2020 by lixiaoqity Loading…
1
7
Always use config to set default value of timeout in check version
#2108 opened Aug 22, 2020 by sunnyakaxd Loading…
1
Propagate future.exception in producer/kafka.py _wait_on_metadata
#2082 opened Jul 14, 2020 by mkromer-tc Loading…
3
Add delete records method support for kafka admin api do-not-merge needs investigation
#2062 opened Jun 1, 2020 by 10101010 Loading…
6
Check client version iif not given
#2048 opened May 12, 2020 by jacopofar Loading…
2
Merge two tests that are very similar
#1891 opened Aug 23, 2019 by jeffwidman Loading…
3
More verbosity on exceptions
#1838 opened Jun 5, 2019 by fcracker79 Loading…
6
KAFKA-4160: Ensure rebalance listener not called with coordinator lock do-not-merge
#1438 opened Mar 10, 2018 by dpkp Loading… 2.0
3
Defer version check until after bootstrap succeeds
#1426 opened Mar 9, 2018 by dpkp Loading… 2.0
5
Config parameter 'coordinator_not_ready_retry_timeout_ms'
#1209 opened Sep 11, 2017 by zembunia Loading…
5
ProTip! Add no:assignee to see everything that’s not assigned.