lib/kafka/protocol/offset_commit_request.rb in ruby-kafka-0.4.0.beta1 vs lib/kafka/protocol/offset_commit_request.rb in ruby-kafka-0.4.0

- old
+ new

@@ -3,10 +3,10 @@ class OffsetCommitRequest # This value signals to the broker that its default configuration should be used. DEFAULT_RETENTION_TIME = -1 def api_key - 8 + OFFSET_COMMIT_API end def api_version 2 end