Log claimed partitions

bsm · Mar 18, 2014 · 97a6afd · 97a6afd
1 parent 4a79c9f
commit 97a6afd
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/lib/fluq/input/kafka.rb b/lib/fluq/input/kafka.rb
@@ -15,7 +15,7 @@ class FluQ::Input::Kafka < FluQ::Input::Base
   # @option options [Integer] :min_bytes smallest amount of data the server should send us.
   #   Default: 0 (send us data as soon as it is ready)
   # @option options [Class] :consumer_class the consumer class to use.
-  #   Ddefault: FluQ::Kafka::Consumer
+  #   Default: FluQ::Kafka::Consumer
   #
   # @raises [ArgumentError] when no topic provided
   #

diff --git a/lib/fluq/kafka/consumer.rb b/lib/fluq/kafka/consumer.rb
@@ -7,6 +7,13 @@ class Poseidon::Connection
 module FluQ
   module Kafka
     class Consumer < Poseidon::ConsumerGroup
+      include FluQ::Mixins::Loggable
+
+      def rebalance!
+        super
+        logger.info "kafka:#{topic}: claimed #{claimed.inspect}"
+      end
+
     end
   end
 end