Skip to content

Commit

Permalink
kafka/client: replace std::vector with chunked vector
Browse files Browse the repository at this point in the history
(cherry picked from commit 2d84607)
  • Loading branch information
IoannisRP authored and vbotbuildovich committed Jan 7, 2025
1 parent 03e4b59 commit 85a7718
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 @@ -238,7 +238,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 @@ -118,7 +118,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 85a7718

Please sign in to comment.