class Fluent::KafkaInput::TopicEntry
Attributes
offset[R]
partition[R]
topic[R]
Public Class Methods
new(topic, partition, offset)
click to toggle source
# File lib/fluent/plugin/in_kafka.rb, line 277 def initialize(topic, partition, offset) @topic = topic @partition = partition @offset = offset end