class Kafka::FetchedMessage

def initialize(message:, topic:, partition:)
  @message = message
  @topic = topic
  @partition = partition
end