lib/fluent/plugin/kafka_producer_ext.rb in fluent-plugin-kafka-0.6.0 vs lib/fluent/plugin/kafka_producer_ext.rb in fluent-plugin-kafka-0.6.1

@@ -17,12 +17,11 @@
         value,
         key,
         topic,
         partition,
         partition_key,
-        create_time,
-        key.to_s.bytesize + value.to_s.bytesize
+        create_time
       )
 
       @target_topics.add(topic)
       @pending_message_queue.write(message)
 
@@ -86,11 +85,10 @@
         value,
         key,
         @topic,
         partition,
         partition_key,
-        create_time,
-        key.to_s.bytesize + value.to_s.bytesize
+        create_time
       )
 
       @pending_message_queue.write(message)
 
       nil