class Kafka::MessageBuffer

def write(value:, key:, topic:, partition:, create_time: Time.now)
  message = Protocol::Message.new(key: key, value: value, create_time: create_time)
  buffer_for(topic, partition) << message
  @size += 1
  @bytesize += message.bytesize
end