Skip to content

Commit 1122775

Browse files
nerhneiroIrina Skvortsova
andauthored
change ConfigSource from -1 to DEFAULT_CONFIG (#20784)
Co-authored-by: Irina Skvortsova <nerhneiro@yandex-team.ru>
1 parent bfb3eb0 commit 1122775

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

ydb/core/kafka_proxy/actors/kafka_describe_configs_actor.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,7 @@ void AddConfigEntry(
157157
configEntry.Name = name;
158158
configEntry.Value = value;
159159
configEntry.ConfigType = (ui32)type;
160+
configEntry.ConfigSource = EConfigSource::DEFAULT_CONFIG;
160161
descrResult.Configs.emplace_back(std::move(configEntry));
161162
}
162163

ydb/core/kafka_proxy/actors/kafka_describe_configs_actor.h

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,16 @@
77

88
namespace NKafka {
99

10+
enum EConfigSource {
11+
UNKNOWN = 0,
12+
DYNAMIC_TOPIC_CONFIG = 1,
13+
DYNAMIC_BROKER_CONFIG = 2,
14+
DYNAMIC_DEFAULT_BROKER_CONFIG = 3,
15+
STATIC_BROKER_CONFIG = 4,
16+
DEFAULT_CONFIG = 5,
17+
DYNAMIC_BROKER_LOGGER_CONFIG = 6,
18+
};
19+
1020
class TDescribeConfigsRequest: public TKafkaTopicRequestCtx {
1121
public:
1222
using TKafkaTopicRequestCtx::TKafkaTopicRequestCtx;

0 commit comments

Comments
 (0)