lib/kafka.rb in ruby-kafka-0.3.13.beta3 vs lib/kafka.rb in ruby-kafka-0.3.13.beta4
- old
+ new
@@ -17,9 +17,10 @@
class UnknownError < ProtocolError
end
class OffsetOutOfRange < ProtocolError
+ attr_accessor :topic, :partition
end
# The request is for a topic or partition that does not exist on the broker.
class UnknownTopicOrPartition < ProtocolError
end