From cfb4a7f55656b2a7b8160adbdd533b23a0ea62a0 Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Mon, 8 Nov 2021 17:44:48 -0700 Subject: [PATCH] kgo: error if RecordReader layout is empty --- pkg/kgo/record_formatter.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/kgo/record_formatter.go b/pkg/kgo/record_formatter.go index 46c3991b..2b1d2160 100644 --- a/pkg/kgo/record_formatter.go +++ b/pkg/kgo/record_formatter.go @@ -966,6 +966,10 @@ func (p *parseRecordBits) set(r parseRecordBits) { *p = *p | r } func (p parseRecordBits) has(r parseRecordBits) bool { return p&r != 0 } func (r *RecordReader) parseReadLayout(layout string) error { + if len(layout) == 0 { + return errors.New("RecordReader: invalid empty format") + } + var ( // If we are reading by size, we parse the layout size into one // of these variables. When reading, we use the captured