Method: Rdkafka::Consumer::Message#partition
- Defined in:
- lib/rdkafka/consumer/message.rb
#partition ⇒ Integer (readonly)
The partition this message was consumed from
13 14 15 |
# File 'lib/rdkafka/consumer/message.rb', line 13 def partition @partition end |