Поддержка автопартиционирования топиков в MVP (перенос из mvp/stable-2024-07)

fix create stream without autopartitioning

Add topics autopartitioning for MVP
fix
add support
apply datastreams patch

Fix empty result of datastreams if kinesisEndpoint is not set
2a51beea2bab550e743f19ec7ee8c5c5eb27ed15

1 files changed, 9 insertions, 1 deletions

diff --git a/library/cpp/protobuf/json/json2proto.cpp b/library/cpp/protobuf/json/json2proto.cpp
index f0ca3adf42..823c471b96 100644
--- a/library/cpp/protobuf/json/json2proto.cpp
+++ b/library/cpp/protobuf/json/json2proto.cpp
@@ -85,7 +85,15 @@ static void JsonString2Duration(const NJson::TJsonValue& json,
                  const google::protobuf::FieldDescriptor& field,
                  const NProtobufJson::TJson2ProtoConfig& config) {
     using namespace google::protobuf;
-    if (!json.GetString() && !config.CastRobust) {
+    if (json.IsMap()) {
+        const auto& m = json.GetMap();
+        Duration duration;
+        duration.set_seconds(m.contains("Seconds") ? m.at("Seconds").GetInteger() : 0);
+        duration.set_nanos(m.contains("Nanos") ? m.at("Nanos").GetInteger() : 0);
+        proto.CopyFrom(duration);
+
+        return;
+    } else if (!json.GetString() && !config.CastRobust) {
         ythrow yexception() << "Invalid type of JSON field '" << field.name() << "': "
                             << "IsString() failed while "
                             << "CPPTYPE_STRING is expected.";