require 'fluq'
require 'fluq/kafka/version'
require 'fluq/kafka/consumer'
require 'fluq/input/kafka'