module Fluent::KafkaPluginUtil