Skip to content

kafka.net: support socket_connection_setup_timeout_ms w/ exp backoff (KIP-601)#3027

Merged
dpkp merged 8 commits into
masterfrom
dpkp/net-connection-timeouts
Jun 3, 2026
Merged

kafka.net: support socket_connection_setup_timeout_ms w/ exp backoff (KIP-601)#3027
dpkp merged 8 commits into
masterfrom
dpkp/net-connection-timeouts

Conversation

@dpkp

@dpkp dpkp commented Jun 3, 2026

Copy link
Copy Markdown
Owner
  • kafka.net.inet: Support timeout_at for inet connections
  • kafka.net.manager: Use socket timeout kwarg instead of call_later disconnect
  • kafka.net.selector: throw self._exc (if set) into pending coro
  • kafka.net.selector: Add timeout_at to wait_write/wait_read
  • Capture final.value from inner coro
  • kafka.net: support socket_connection_setup_timeout_ms w/ exp backoff (KIP-601)
  • bootstrap: pass timeout to get_connection
  • kafka.net.connection: wrap version check + sasl with initialize() with optional timeout

@dpkp dpkp merged commit 7250337 into master Jun 3, 2026
19 checks passed
@dpkp dpkp deleted the dpkp/net-connection-timeouts branch June 3, 2026 23:26
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant