Skip to content
Navigation Menu
Sign in
Appearance settings
Platform
AI CODE CREATION
GitHub Copilot
Write better code with AI
GitHub Copilot app
Direct agents from issue to merge
MCP Registry
Integrate external tools
DEVELOPER WORKFLOWS
Actions
Automate any workflow
Codespaces
Instant dev environments
Issues
Plan and track work
Code Review
Manage code changes
Code Quality
Enforce quality at merge
APPLICATION SECURITY
GitHub Advanced Security
Find and fix vulnerabilities
Code security
Secure your code as you build
Secret protection
Stop leaks before they start
EXPLORE
Why GitHub
Documentation
Blog
Changelog
Marketplace
View all features
Solutions
BY COMPANY SIZE
Enterprises
Small and medium teams
Startups
Nonprofits
BY USE CASE
App Modernization
DevSecOps
DevOps
CI/CD
View all use cases
BY INDUSTRY
Healthcare
Financial services
Manufacturing
Government
View all industries
View all solutions
Resources
EXPLORE BY TOPIC
AI
Software Development
DevOps
Security
View all topics
EXPLORE BY TYPE
Customer stories
Events & webinars
Ebooks & reports
Business insights
GitHub Skills
SUPPORT & SERVICES
Documentation
Customer support
Community forum
Trust center
Partners
View all resources
Open Source
COMMUNITY
GitHub Sponsors
Fund open source developers
PROGRAMS
Security Lab
Maintainer Community
Accelerator
GitHub Stars
Archive Program
REPOSITORIES
Topics
Trending
Collections
Enterprise
ENTERPRISE SOLUTIONS
Enterprise platform
AI-powered developer platform
AVAILABLE ADD-ONS
GitHub Advanced Security
Enterprise-grade security features
Copilot for Business
Enterprise-grade AI features
Premium Support
Enterprise-grade 24/7 support
Pricing
Search
/
Sign in
Sign up
Appearance settings
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
{{ message }}
dpkp
/
kafka-python
Public
Notifications
You must be signed in to change notification settings
Fork
1.5k
Star
5.9k
Code
Issues
16
Pull requests
2
Actions
Security and quality
0
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Security and quality
Insights
Actions: dpkp/kafka-python
Actions
All workflows
Workflows
CodeQL
CodeQL
Dependabot Updates
Dependabot Updates
Dependency Graph
Dependency Graph
Flakey test repro
Flakey test repro
Python Package
Python Package
Show more workflows...
Management
Caches
Python Package
Python Package
Actions
Loading...
Loading
Sorry, something went wrong.
Uh oh!
There was an error while loading.
Please reload this page
.
will be ignored since log searching is not yet available
Show workflow options
Create status badge
Create status badge
Loading
Uh oh!
There was an error while loading.
Please reload this page
.
python-package.yml
will be ignored since log searching is not yet available
1,300 workflow runs
1,300 workflow runs
Event
Filter by Event
Sorry, something went wrong.
Filter
Loading
Sorry, something went wrong.
No matching events.
Status
Filter by Status
Sorry, something went wrong.
Filter
Loading
Sorry, something went wrong.
No matching statuses.
Branch
Filter by Branch
Sorry, something went wrong.
Filter
Loading
Sorry, something went wrong.
No matching branches.
Actor
Filter by Actor
Sorry, something went wrong.
Filter
Loading
Sorry, something went wrong.
No matching users.
Wire socket_connection_setup_timeout_ms / max_ms configs from manager to user-facing clients (consumer/producer/admin)
Python Package
#2072:
Pull request
#3129
opened by
dpkp
5m 37s
dpkp/socket-connection-setup-timeout
dpkp/socket-connection-setup-timeout
5m 37s
View #3129
View workflow file
Convert KafkaSSLTransport to sans-IO transport/protocol bridge
Python Package
#2071:
Pull request
#3128
synchronize by
dpkp
5m 28s
dpkp/kafka-ssl-wrapper
dpkp/kafka-ssl-wrapper
5m 28s
View #3128
View workflow file
Convert KafkaSSLTransport to sans-IO transport/protocol bridge
Python Package
#2070:
Pull request
#3128
synchronize by
dpkp
5m 33s
dpkp/kafka-ssl-wrapper
dpkp/kafka-ssl-wrapper
5m 33s
View #3128
View workflow file
Convert KafkaSSLTransport to sans-IO transport/protocol bridge
Python Package
#2069:
Pull request
#3128
opened by
dpkp
1m 6s
dpkp/kafka-ssl-wrapper
dpkp/kafka-ssl-wrapper
1m 6s
View #3128
View workflow file
Move all backend modules to kafka.net.backend.* (#3127)
Python Package
#2068:
Commit
a48ac06
pushed by
dpkp
5m 53s
master
master
5m 53s
View workflow file
Move all backend modules to kafka.net.backend.*
Python Package
#2067:
Pull request
#3127
synchronize by
dpkp
5m 44s
dpkp/net-backend-module
dpkp/net-backend-module
5m 44s
View #3127
View workflow file
Move all backend modules to kafka.net.backend.*
Python Package
#2066:
Pull request
#3127
opened by
dpkp
6m 1s
dpkp/net-backend-module
dpkp/net-backend-module
6m 1s
View #3127
View workflow file
net: Drop unused transport/protocol methods; rename Transport->NetTra…
Python Package
#2065:
Commit
e9ea2f2
pushed by
dpkp
5m 37s
master
master
5m 37s
View workflow file
net: Drop unused transport/protocol methods; rename Transport->NetTransport; add NetProtocol
Python Package
#2064:
Pull request
#3126
synchronize by
dpkp
5m 44s
dpkp/net-backend-cleanups
dpkp/net-backend-cleanups
5m 44s
View #3126
View workflow file
net: Drop unused transport/protocol methods; rename Transport->NetTransport; add NetProtocol
Python Package
#2063:
Pull request
#3126
opened by
dpkp
5m 37s
dpkp/net-backend-cleanups
dpkp/net-backend-cleanups
5m 37s
View #3126
View workflow file
Warn if coro did not complete before deadline (#3125)
Python Package
#2062:
Commit
b11d749
pushed by
dpkp
5m 45s
master
master
5m 45s
View workflow file
Warn if coro did not complete before deadline
Python Package
#2061:
Pull request
#3125
opened by
dpkp
5m 50s
dpkp/deadline-warnings
dpkp/deadline-warnings
5m 50s
View #3125
View workflow file
Wire existing timeouts to net.run event.wait (#3124)
Python Package
#2060:
Commit
7874d5e
pushed by
dpkp
5m 55s
master
master
5m 55s
View workflow file
Wire existing timeouts to net.run event.wait
Python Package
#2059:
Pull request
#3124
synchronize by
dpkp
5m 32s
dpkp/default-api-timeout-ms-wiring
dpkp/default-api-timeout-ms-wiring
5m 32s
View #3124
View workflow file
Wire existing timeouts to net.run event.wait
Python Package
#2058:
Pull request
#3124
opened by
dpkp
5m 37s
dpkp/default-api-timeout-ms-wiring
dpkp/default-api-timeout-ms-wiring
5m 37s
View #3124
View workflow file
Add default_api_timeout_ms config; raise KafkaTimeoutError from user-…
Python Package
#2057:
Commit
664fe5b
pushed by
dpkp
4m 49s
master
master
4m 49s
View workflow file
Add default_api_timeout_ms config; raise KafkaTimeoutError from user-side of net.run()
Python Package
#2056:
Pull request
#3123
synchronize by
dpkp
4m 37s
dpkp/default-api-timeout-ms
dpkp/default-api-timeout-ms
4m 37s
View #3123
View workflow file
Add default_api_timeout_ms config; raise KafkaTimeoutError from user-side of net.run()
Python Package
#2055:
Pull request
#3123
synchronize by
dpkp
4m 35s
dpkp/default-api-timeout-ms
dpkp/default-api-timeout-ms
4m 35s
View #3123
View workflow file
Add default_api_timeout_ms config; raise KafkaTimeoutError from user-side of net.run()
Python Package
#2054:
Pull request
#3123
opened by
dpkp
1m 7s
dpkp/default-api-timeout-ms
dpkp/default-api-timeout-ms
1m 7s
View #3123
View workflow file
net: simplify backend transport/protocol interface; fixup test future…
Python Package
#2053:
Commit
8a97754
pushed by
dpkp
4m 56s
master
master
4m 56s
View workflow file
net: simplify backend transport/protocol interface; fixup test futures
Python Package
#2052:
Pull request
#3120
synchronize by
dpkp
4m 33s
dpkp/backend-cleanups
dpkp/backend-cleanups
4m 33s
View #3120
View workflow file
net: manager owns net lifecycle (auto-start/close, ownership-gated) (…
Python Package
#2051:
Commit
dd4a178
pushed by
dpkp
4m 51s
master
master
4m 51s
View workflow file
net: simplify backend transport/protocol interface; fixup test futures
Python Package
#2050:
Pull request
#3120
opened by
dpkp
4m 32s
dpkp/backend-cleanups
dpkp/backend-cleanups
4m 32s
View #3120
View workflow file
Fix OverflowError in offsets_for_times() when timestamp is non-finite float
Python Package
#2049:
Pull request
#3119
opened by
koteshyelamati
4m 54s
koteshyelamati:koteshyelamati-patch-1
koteshyelamati:koteshyelamati-patch-1
4m 54s
View #3119
View workflow file
net: manager owns net lifecycle (auto-start/close, ownership-gated)
Python Package
#2048:
Pull request
#3118
synchronize by
dpkp
4m 39s
dpkp/manager-owns-net
dpkp/manager-owns-net
4m 39s
View #3118
View workflow file
Previous
1
2
3
4
5
…
51
52
Next
You can’t perform that action at this time.