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