Method: Kafka::FetchedMessage#partition

Defined in:
lib/kafka/fetched_message.rb

#partitionInteger (readonly)

Returns the partition number that the message was written to.

Returns:

  • (Integer)

    the partition number that the message was written to.



9
10
11
# File 'lib/kafka/fetched_message.rb', line 9

def partition
  @partition
end