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