Skip to content

Add configurable Kafka proxy listen address#29

Draft
zinal wants to merge 6 commits into
mainfrom
cursor/kafka-listen-address-af67
Draft

Add configurable Kafka proxy listen address#29
zinal wants to merge 6 commits into
mainfrom
cursor/kafka-listen-address-af67

Conversation

@zinal

@zinal zinal commented Jul 15, 2026

Copy link
Copy Markdown
Owner

Summary

Adds the ability to configure the network address on which Kafka Proxy binds its listener, instead of always using the hardcoded default ::.

Changes

  • kafka_proxy_config.listening_address (proto field ListeningAddress, default [::]) — YAML configuration parameter
  • --kafka-listen-address — command-line option for ydbd and config parser
  • Wire the setting into TListenerSettings.Address in TKafkaProxyServiceInitializer and test client setup
  • Update documentation (EN/RU) and test harness (kikimr_config.py)

Usage

kafka_proxy_config:
  enable_kafka_proxy: true
  listening_port: 9092
  listening_address: "127.0.0.1"
ydbd --kafka-port 9092 --kafka-listen-address 127.0.0.1 ...

Notes

  • Default [::] preserves existing behavior (listen on all interfaces).
  • listening_address controls bind address only; public_host still controls the address advertised to Kafka clients.
  • listening_address can be set independently of --kafka-port / listening_port.
Open in Web Open in Cursor 

@zinal
zinal force-pushed the cursor/kafka-listen-address-af67 branch from 21dcc1f to 0db38be Compare July 16, 2026 09:58
cursoragent and others added 5 commits July 17, 2026 10:15
Introduce listening_address in kafka_proxy_config and --kafka-listen-address
CLI option to control the bind address used by TListenerSettings when starting
the Kafka proxy listener. Defaults to [::] to preserve existing behavior.

Co-authored-by: Maksim Zinal <zinal@ydb.tech>
Co-authored-by: Ilnaz Nizametdinov <i.nizametdinov@gmail.com>
@zinal
zinal force-pushed the cursor/kafka-listen-address-af67 branch from 0db38be to f37b7b3 Compare July 17, 2026 07:15
The bracketed IPv6 notation is not parsed by MakeAddress/IsIPv6 in
sock64.h, which caused ydbd to crash on startup when Kafka proxy was
enabled. Use :: to match TListenerSettings default and preserve
existing bind behavior.

Co-authored-by: Maksim Zinal <zinal@ydb.tech>
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.

2 participants