class Fluent::Plugin::RdKafkaGroupInput::Batch

Attributes

messages[R]
topic[R]

Public Class Methods

new(topic) click to toggle source
# File lib/fluent/plugin/in_rdkafka_group.rb, line 194
def initialize(topic)
  @topic = topic
  @messages = []
end