lib/racecar/consumer.rb in racecar-2.9.0 vs lib/racecar/consumer.rb in racecar-2.10.0.beta1

@@ -35,9 +35,13 @@
       )
         topics.each do |topic|
           subscriptions << Subscription.new(topic, start_from_beginning, max_bytes_per_partition, additional_config)
         end
       end
+
+      # Rebalance hooks for subclasses to override
+      def on_partitions_assigned(rebalance_event); end
+      def on_partitions_revoked(rebalance_event); end
     end
 
     def configure(producer:, consumer:, instrumenter: NullInstrumenter, config: Racecar.config)
       @producer = producer
       @delivery_handles = []