class Kafka::MessageBuffer

def concat(messages, topic:, partition:)
  buffer_for(topic, partition).concat(messages)
  @size += messages.count
  @bytesize += messages.map(&:bytesize).reduce(0, :+)
end