pandaproxy: Enable streaming requests

Signed-off-by: Ben Pope <ben@redpanda.com> (cherry picked from commit c934757)
redpanda-data · Jul 16, 2024 · bba5270 · bba5270
1 parent b098de6
commit bba5270
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/v/pandaproxy/rest/handlers.cc b/src/v/pandaproxy/rest/handlers.cc
@@ -456,7 +456,7 @@ post_consumer_offsets(server::request_t rq, server::reply_t rp) {
     auto member_id{parse::request_param<kafka::member_id>(*rq.req, "instance")};
 
     // If the request is empty, commit all offsets
-    auto req_data = rq.req->content.length() == 0
+    auto req_data = rq.req->content_length == 0
                       ? std::vector<kafka::offset_commit_request_topic>()
                       : ppj::partition_offsets_request_to_offset_commit_request(
                         co_await ppj::rjson_parse(

diff --git a/src/v/pandaproxy/server.cc b/src/v/pandaproxy/server.cc
@@ -154,6 +154,7 @@ server::server(
     _api20.set_api_doc(_server._routes);
     _api20.register_api_file(_server._routes, header);
     _api20.add_definitions_file(_server._routes, definitions);
+    _server.set_content_streaming(true);
 }
 
 /*