lib/kafka/protocol/group_coordinator_request.rb in ruby-kafka-0.4.0.beta1 vs lib/kafka/protocol/group_coordinator_request.rb in ruby-kafka-0.4.0
- old
+ new
@@ -4,10 +4,10 @@
def initialize(group_id:)
@group_id = group_id
end
def api_key
- 10
+ GROUP_COORDINATOR_API
end
def encode(encoder)
encoder.write_string(@group_id)
end