From 0f7c015bf1505c3a3526168de205608b393b7ce8 Mon Sep 17 00:00:00 2001 From: Alexey Zatelepin Date: Fri, 3 Jan 2025 16:15:56 +0100 Subject: [PATCH] TO REMOVE: print create_table catalog request json --- src/v/iceberg/rest_client/catalog_client.cc | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/v/iceberg/rest_client/catalog_client.cc b/src/v/iceberg/rest_client/catalog_client.cc index 668ff484ec84f..5cbbeacd561d2 100644 --- a/src/v/iceberg/rest_client/catalog_client.cc +++ b/src/v/iceberg/rest_client/catalog_client.cc @@ -14,6 +14,7 @@ #include "http/request_builder.h" #include "http/utils.h" #include "iceberg/json_writer.h" +#include "iceberg/logger.h" #include "iceberg/rest_client/entities.h" #include "iceberg/rest_client/json.h" #include "iceberg/table_requests_json.h" @@ -216,6 +217,13 @@ ss::future> catalog_client::create_table( .with_bearer_auth(token.value()) .with_content_type(json_content_type); + auto json_buf = serialize_payload_as_json(req); + ss::sstring json_str; + for (const auto& frag : json_buf) { + json_str.append(frag.get(), frag.size()); + } + vlog(log.info, "FFF {}", json_str); + co_return (co_await perform_request( rtc, http_request, serialize_payload_as_json(req))) .and_then(parse_json)