kafka_session.rb in kafka_session-0.3.1

- old
+ new

@@ -1,5 +1,7 @@
+require 'kafka_session/producer'
 require "kafka_session/version"
+
 require 'kafka_session/delivered_message'
 require 'kafka_session/message'
 
 require 'securerandom'
 require 'active_support/time'