Method: Rdkafka::Consumer::Message#partition

Defined in:
lib/rdkafka/consumer/message.rb

#partitionInteger (readonly)

The partition this message was consumed from

Returns:

  • (Integer)

13
14
15
# File 'lib/rdkafka/consumer/message.rb', line 13

def partition
  @partition
end