Class: Fluent::KafkaInput::TopicEntry

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/in_kafka.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(topic, partition, offset) ⇒ TopicEntry

Returns a new instance of TopicEntry.



355
356
357
358
359
 
# File 'lib/fluent/plugin/in_kafka.rb', line 355

def initialize(topic, partition, offset)
  @topic = topic
  @partition = partition
  @offset = offset
end

Instance Attribute Details

#offset ⇒ Object (readonly)

Returns the value of attribute offset.



360
361
362
 
# File 'lib/fluent/plugin/in_kafka.rb', line 360

def offset
  @offset
end

#partition ⇒ Object (readonly)

Returns the value of attribute partition.



360
361
362
 
# File 'lib/fluent/plugin/in_kafka.rb', line 360

def partition
  @partition
end

#topic ⇒ Object (readonly)

Returns the value of attribute topic.



360
361
362
 
# File 'lib/fluent/plugin/in_kafka.rb', line 360

def topic
  @topic
end