Method: Kafka::FetchedMessage#initialize

Defined in:
lib/kafka/fetched_message.rb

#initialize(message:, topic:, partition:) ⇒ FetchedMessage

Returns a new instance of FetchedMessage.



11
12
13
14
15
 
# File 'lib/kafka/fetched_message.rb', line 11

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