Aborted transactional data included in response when setting read_committed isolation level in reader #1332

// snippets
	r := segment_kafka.NewReader(
		segment_kafka.ReaderConfig{
			Brokers: []string{
				"my_broker:9092",
			},
			Topic:          "my_topic",
			GroupID:        fmt.Sprintf("testing_%s", strconv.Itoa(rand.Int())),
			StartOffset:    segment_kafka.FirstOffset,
			MaxBytes:       10e6,
			IsolationLevel: segment_kafka.ReadCommitted,
		},
	)

	ctx, cancel := context.WithTimeout(context.TODO(), 10*time.Second)
	defer cancel()
	messages := []segment_kafka.Message{}
	for {
		select {
		case <-ctx.Done():
			return
		default:
			ev, err := r.ReadMessage(ctx)
			if err != nil {
				logger.Error("failed to read message", zap.Error(err))
				continue
			}
			logger.Info("Consumed event from topic",
				zap.String("topic", ev.Topic),
				zap.String("key", string(ev.Key)),
				zap.String("value", string(ev.Value)),
				zap.Int64("offset", ev.Offset),
				zap.Any("partition", ev.Partition),
			)
			messages = append(messages, ev)
		}
	}