Skip to content

Commit

Permalink
Merge pull request #24705 from vbotbuildovich/backport-pr-24582-v24.3…
Browse files Browse the repository at this point in the history
….x-168

[v24.3.x] kafka/client: replace std::vector with chunked vector
  • Loading branch information
BenPope authored Jan 8, 2025
2 parents 50675ed + 7996b4e commit 8e604fc
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion src/v/kafka/client/client.cc
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,7 @@ ss::future<produce_response::partition> client::produce_record_batch(
}

ss::future<produce_response> client::produce_records(
model::topic topic, std::vector<record_essence> records) {
model::topic topic, chunked_vector<record_essence> records) {
absl::node_hash_map<model::partition_id, storage::record_batch_builder>
partition_builders;

Expand Down
2 changes: 1 addition & 1 deletion src/v/kafka/client/client.h
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ class client {
model::topic_partition tp, model::record_batch&& batch);

ss::future<produce_response>
produce_records(model::topic topic, std::vector<record_essence> batch);
produce_records(model::topic topic, chunked_vector<record_essence> batch);

ss::future<list_offsets_response> list_offsets(model::topic_partition tp);

Expand Down
2 changes: 1 addition & 1 deletion src/v/pandaproxy/json/requests/produce.h
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ class produce_request_handler {

public:
using Ch = typename Encoding::Ch;
using rjson_parse_result = std::vector<kafka::client::record_essence>;
using rjson_parse_result = chunked_vector<kafka::client::record_essence>;
rjson_parse_result result;

explicit produce_request_handler(serialization_format fmt)
Expand Down

0 comments on commit 8e604fc

Please sign in to comment.