delete useless line that crashed sarama for empty messages (#911)

confluentinc · Jul 1, 2021 · 6127661 · 6127661
1 parent c06fd6d
commit 6127661
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/internal/cmd/kafka/sarama.go b/internal/cmd/kafka/sarama.go
@@ -81,8 +81,7 @@ func (*GroupHandler) Cleanup(_ sarama.ConsumerGroupSession) error { return nil }
 func (h *GroupHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error {
 	for msg := range claim.Messages() {
 		value := msg.Value
-		// For messages with schema, first byte is magic byte 0x0.
-		_ = value[0]
+
 		if h.Properties.PrintKey {
 			key := msg.Key
 			var keyString string