Contents

require 'fluq'
require 'fluq/kafka/version'
require 'poseidon_cluster'
require 'fluq/input/kafka'

class Poseidon::Connection
  TCPSocket = Celluloid::IO::TCPSocket
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluq-kafka-0.8.0	lib/fluq/kafka.rb