Skip to content

/ kafka-python

New pull request New
25 Open 854 Closed
25 Open 854 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels.
Projects
Filter by project
Milestones
Filter by milestone
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
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
docs: note flush behaviour of producer's .close()
#2101 opened Aug 7, 2020 by hraban
Handle OSError to properly recycle SSL connection, fix infinite loop
#2100 opened Aug 7, 2020 by sibiryakov
Fix typo
#2096 opened Jul 31, 2020 by haracejacob
Avoid 100% CPU usage while socket is closed
#2091 opened Jul 23, 2020 by orange-kao
2
Propagate future.exception in producer/kafka.py _wait_on_metadata
#2082 opened Jul 14, 2020 by mkromer-tc
Update example.py
#2081 opened Jul 14, 2020 by Mostafa-Elmenbawy
1
Add kafka.structs docstrings
#2080 opened Jul 14, 2020 by Mostafa-Elmenbawy
1
1
Added crc32c extra requirement as per issue #2068
#2069 opened Jun 23, 2020 by mishas
2
Fix #1985: fix consumer deadlock when heartbeat thread request timeout
#2064 opened Jun 9, 2020 by huangcuiyang
2
Add delete records method support for kafka admin api
#2062 opened Jun 1, 2020 by 10101010
Try to fix pylint issue
#2058 opened May 26, 2020 by tvoinarovskyi
KIP-54: Implement sticky partition assignment strategy
#2057 opened May 26, 2020 by aynroot
3
Check client version iif not given
#2048 opened May 12, 2020 by jacopofar
1
fixed the broken compatibility page link
#2045 opened May 7, 2020 by anuragrana
producer/kafka: Disable logging during object destruction
#2043 opened May 1, 2020 by gioele
1
1
Feature delete consumergroups
#2040 opened Apr 24, 2020 by swenzel
4
Enhancement for Kafka Admin Client's "Describe Consumer Group"
#2035 opened Apr 9, 2020 by Apurva007 • Changes requested
31
Add support for `zstd` compression
#2021 opened Mar 15, 2020 by gabriel-tincu • Approved
42
Merge two tests that are very similar
#1891 opened Aug 23, 2019 by jeffwidman
3
More verbosity on exceptions
#1838 opened Jun 5, 2019 by fcracker79
6
KAFKA-4160: Ensure rebalance listener not called with coordinator lock
do-not-merge
#1438 opened Mar 10, 2018 by dpkp • Approved 2.0
2
Defer version check until after bootstrap succeeds
#1426 opened Mar 9, 2018 by dpkp 2.0
4
Config parameter 'coordinator_not_ready_retry_timeout_ms'
#1209 opened Sep 11, 2017 by zembunia
4
Allow injecting clients into Kafka Consumers and Producers.
#735 opened Jun 21, 2016 by Julian
13
Console commands
#119 opened Feb 4, 2014 by rdiomar
11
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.
You can’t perform that action at this time.