diff options
| author | FloatingCrowbar <komels@ydb.tech> | 2025-01-24 15:16:24 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-01-24 15:16:24 +0300 |
| commit | 066cc819fba91c72a5dcd631348f2a817ab0c07c (patch) | |
| tree | 6bfbf9e09e150095645b50601d36d81ae64d2b52 | |
| parent | 6a1a387b2638717e8192adc645e3e885ece00f11 (diff) | |
| download | ydb-066cc819fba91c72a5dcd631348f2a817ab0c07c.tar.gz | |
Add kafka-port option to binary (#13799)
| -rw-r--r-- | ydb/core/config/init/init_impl.h | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/ydb/core/config/init/init_impl.h b/ydb/core/config/init/init_impl.h index 4d72f3d76cd..176e93d8df7 100644 --- a/ydb/core/config/init/init_impl.h +++ b/ydb/core/config/init/init_impl.h @@ -318,6 +318,7 @@ struct TCommonAppOptions { TString GRpcPublicHost = ""; ui32 GRpcPublicPort = 0; ui32 GRpcsPublicPort = 0; + ui32 KafkaPort = 0; TString PGWireAddress = ""; ui32 PGWirePort = 0; TVector<TString> GRpcPublicAddressesV4; @@ -388,6 +389,7 @@ struct TCommonAppOptions { opts.AddLongOption("grpc-public-host", "set public gRPC host for discovery").RequiredArgument("HOST").StoreResult(&GRpcPublicHost); opts.AddLongOption("grpc-public-port", "set public gRPC port for discovery").RequiredArgument("PORT").StoreResult(&GRpcPublicPort); opts.AddLongOption("grpcs-public-port", "set public gRPC SSL port for discovery").RequiredArgument("PORT").StoreResult(&GRpcsPublicPort); + opts.AddLongOption("kafka-port", "enable kafka proxy to listen on port").OptionalArgument("PORT").StoreResult(&KafkaPort); opts.AddLongOption("pgwire-address", "set host for listen postgres protocol").RequiredArgument("ADDR").StoreResult(&PGWireAddress); opts.AddLongOption("pgwire-port", "set port for listen postgres protocol").OptionalArgument("PORT").StoreResult(&PGWirePort); opts.AddLongOption("grpc-public-address-v4", "set public ipv4 address for discovery").RequiredArgument("ADDR").EmplaceTo(&GRpcPublicAddressesV4); @@ -604,6 +606,12 @@ struct TCommonAppOptions { } ConfigUpdateTracer.AddUpdate(NKikimrConsole::TConfigItem::GRpcConfigItem, TConfigItemInfo::EUpdateKind::UpdateExplicitly); } + if (KafkaPort) { + auto& conf = *appConfig.MutableKafkaProxyConfig(); + conf.SetEnableKafkaProxy(true); + conf.SetListeningPort(KafkaPort); + ConfigUpdateTracer.AddUpdate(NKikimrConsole::TConfigItem::KafkaProxyConfigItem, TConfigItemInfo::EUpdateKind::UpdateExplicitly); + } if (PGWireAddress) { appConfig.MutableLocalPgWireConfig()->SetAddress(PGWireAddress); } |