func (pc *partitionConsumer) Messages() <-chan *sarama.ConsumerMessage {
	return pc.dispatcher.Messages()
}
Messages returns the read channel for the messages that are returned by
the broker.
package otelsarama
import (
	"github.com/Shopify/sarama"
)
type partitionConsumer struct {
	sarama.PartitionConsumer
	dispatcher consumerMessagesDispatcher
}