lib/kafka.rb in ruby-kafka-0.1.0.pre.alpha2 vs lib/kafka.rb in ruby-kafka-0.1.0.pre.beta1

@@ -11,9 +11,12 @@
   InvalidMessageSize = Class.new(Error)
   LeaderNotAvailable = Class.new(Error)
   NotLeaderForPartition = Class.new(Error)
   RequestTimedOut = Class.new(Error)
 
+  # Raised if a replica is expected on a broker, but is not. Can be safely ignored.
+  ReplicaNotAvailable = Class.new(Error)
+
   def self.new(**options)
     Client.new(**options)
   end
 end