lib/racecar/message.rb in racecar-2.0.0.alpha3 vs lib/racecar/message.rb in racecar-2.0.0.beta1

@@ -6,10 +6,14 @@
 
     def initialize(rdkafka_message)
       @rdkafka_message = rdkafka_message
     end
 
-    def_delegators :@rdkafka_message, :topic, :partition, :offset, :key, :value, :headers
+    def_delegators :@rdkafka_message, :topic, :partition, :offset, :key, :headers
+
+    def value
+      @rdkafka_message.payload
+    end
 
     def create_time
       @rdkafka_message.timestamp
     end