Skip to content

Navigation Menu

Explore
By company size
By use case
By industry
View all solutions
Topics
- AI
- DevOps
- Security
- Software Development
- View all
Explore
- GitHub Sponsors
  Fund open source developers
- The ReadME Project
  GitHub community articles
Repositories
- Enterprise platform
  AI-powered developer platform
Available add-ons
Pricing

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

Sign up

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

dpkp / kafka-python Public

Notifications You must be signed in to change notification settings
Fork 1.4k
Star 5.7k

Code
Issues 41
Pull requests 2
Actions
Projects
Wiki
Security
Insights

Additional navigation options

Code
Issues
Pull requests
Actions
Projects
Wiki
Security
Insights

KAFKA-3888 Use background thread to process consumer heartbeats#1266

Merged

dpkp merged 13 commits intomasterdpkp/kafka-python:masterfrom

KAFKA_3888_heartbeat_threaddpkp/kafka-python:KAFKA_3888_heartbeat_threadCopy head branch name to clipboard

Dec 21, 2017

Conversation Commits13 (13)Checks Files changed

Commits

Commits on Dec 21, 2017

KAFKA-3888: use background thread for consumer heartbeats
dpkp
committed
Updates from review
dpkp
committed
Whitespace fixup
dpkp
committed
Handle no group, no broker support, and/or manually-assigned partitions in coordinator.poll()
dpkp
committed
Fix consumer iterator internal timeout to just check when coordinator needs next poll
dpkp
committed
coordinator.poll should not use join group with 0.8.2 brokers
dpkp
committed
Drop heartbeat_thread reference after close
dpkp
committed
Add simple test for consumer heartbeat thread
dpkp
committed
Handle session_timeout_ms / max_poll_interval_ms defaults differently for old brokers
dpkp
committed
Fixup KafkaConfigurationError
dpkp
committed
Fixup comments
dpkp
committed
fix tests
dpkp
committed
Fix lookup future is_done check
dpkp
committed

Footer

© 2025 GitHub, Inc.

Footer navigation

Terms
Privacy
Security
Status
Docs
Contact

You can’t perform that action at this time.