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 351
def initialize(topic, partition, offset)
  @topic = topic
  @partition = partition
  @offset = offset
end