File tree 1 file changed +9
-2
lines changed
1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ using stop_parser = batch_consumer::stop_parser;
40
40
static ss::future<result<iobuf>> verify_read_iobuf (
41
41
ss::input_stream<char >& in,
42
42
size_t expected,
43
- const char * msg,
43
+ std::string_view msg,
44
44
bool recover = false ) {
45
45
auto b = co_await read_iobuf_exactly (in, expected);
46
46
@@ -203,7 +203,14 @@ void continuous_batch_parser::add_bytes_and_reset() {
203
203
ss::future<result<stop_parser>> continuous_batch_parser::consume_records () {
204
204
auto sz = _header->size_bytes - model::packed_record_batch_header_size;
205
205
return verify_read_iobuf (
206
- get_stream (), sz, " parser::consume_records" , _recovery)
206
+ get_stream (),
207
+ sz,
208
+ fmt::format (
209
+ " parser::consume_records (record_batch_header: {}, batch "
210
+ " consumer: {}) " ,
211
+ *_header,
212
+ *_consumer),
213
+ _recovery)
207
214
.then ([this ](result<iobuf> record) -> ss::future<result<stop_parser>> {
208
215
if (!record) {
209
216
return ss::make_ready_future<result<stop_parser>>(record.error ());
You can’t perform that action at this time.
0 commit comments