P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 3 days ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Sep 23, 2025 — Sep 23, 2026 Showing page 1 of 100 Search / Filter on:
build(deps): bump github/codeql-action from 4.37.7 to 4.37.9 (#3155)	dependabot[bot]	More...				22 days ago
build(deps): bump actions/setup-java from 5 to 6 (#3154)	dependabot[bot]	More...				22 days ago
build(deps): bump github/codeql-action from 4.37.6 to 4.37.7 (#3151)	dependabot[bot]	More...				about 1 month ago
build(deps): bump github/codeql-action from 4.37.4 to 4.37.6 (#3149)	dependabot[bot]	More...				about 1 month ago
Fix JsonSerializer returning None and raising TypeError on deserialize (#3150)	David Elias Sandoval Bernitta	More...				about 1 month ago
Fix create_partitions sending empty assignments array instead of null (#3148)	Dana Powers	More...				about 2 months ago
build(deps): bump github/codeql-action from 4 to 4.37.4 (#3145)	dependabot[bot]	More...				about 2 months ago
Move call_soon_with_future / _invoke -> NetBackend base class (#3143)	Dana Powers	More...				about 2 months ago
Use net not manager for .run / .create_future (#3142)	Dana Powers	More...				about 2 months ago
net: Implement await_for/wait_for in net backend (#3141)	Dana Powers	More...				about 2 months ago
net: convert NetBackend contract from Protocol to ABC (#3140)	Dana Powers	More...				2 months ago
Simplify backend api contract: merge call_soon w/ call_soon_threadsafe (#3139)	Dana Powers	More...				2 months ago
Add backend e2e tests against both selector + asyncio (#3137)	Dana Powers	More...				2 months ago
Use sans-io protocol classes for proxy connections (#3136)	Dana Powers	More...				2 months ago
net: merge backend/inet into backend/selector; add backend.getaddrinfo() (#3134)	Dana Powers	More...				2 months ago
Fix stuck partitions retained after rebalance when using listener' (#3132)	Dana Powers	More...				2 months ago
build(deps): bump actions/setup-python from 6 to 7 (#3135)	dependabot[bot]	More...				2 months ago
Move KafkaSSLTransport -> kafka.net.ssl (#3133)	Dana Powers	More...				2 months ago
Wire socket_connection_setup_timeout_ms / max_ms configs from manager to user-facing clients (consumer/producer/admin) (#3129)	Dana Powers	More...				2 months ago
Convert KafkaSSLTransport to sans-IO transport/protocol bridge (#3128)	Dana Powers	More...				2 months ago
Move all backend modules to kafka.net.backend.* (#3127)	Dana Powers	More...				2 months ago
net: Drop unused transport/protocol methods; rename Transport->NetTransport; add NetProtocol (#3126)	Dana Powers	More...				2 months ago
Warn if coro did not complete before deadline (#3125)	Dana Powers	More...				2 months ago
Wire existing timeouts to net.run event.wait (#3124)	Dana Powers	More...				2 months ago
Add default_api_timeout_ms config; raise KafkaTimeoutError from user-side of net.run() (#3123)	Dana Powers	More...				2 months ago
net: simplify backend transport/protocol interface; fixup test futures (#3120)	Dana Powers	More...				3 months ago
net: manager owns net lifecycle (auto-start/close, ownership-gated) (#3118)	Dana Powers	More...				3 months ago
kafka.net: AsyncioBackend (#3117)	Dana Powers	More...				3 months ago
net: add net= backend selection with auto-detect (#3116)	Dana Powers	More...				3 months ago
net: define the NetBackend loop-surface contract (#3115)	Dana Powers	More...				3 months ago

←
1
2
3
4
5
6
7
8
9
…
99
100
→