lib/racecar/message.rb in racecar-2.1.1 vs lib/racecar/message.rb in racecar-2.2.0

@@ -4,11 +4,14 @@
 
 module Racecar
   class Message
     extend Forwardable
 
-    def initialize(rdkafka_message)
+    attr_reader :retries_count
+
+    def initialize(rdkafka_message, retries_count: nil)
       @rdkafka_message = rdkafka_message
+      @retries_count   = retries_count
     end
 
     def_delegators :@rdkafka_message, :topic, :partition, :offset, :key, :headers
 
     def value