lib/kafka/fetcher.rb in ruby-kafka-1.0.0 vs lib/kafka/fetcher.rb in ruby-kafka-1.1.0.beta1

@@ -2,10 +2,10 @@
 
 require "kafka/fetch_operation"
 
 module Kafka
   class Fetcher
-    attr_reader :queue
+    attr_reader :queue, :max_wait_time
 
     def initialize(cluster:, logger:, instrumenter:, max_queue_size:, group:)
       @cluster = cluster
       @logger = TaggedLogger.new(logger)
       @instrumenter = instrumenter