lib/kafka/protocol.rb in ruby-kafka-0.6.2 vs lib/kafka/protocol.rb in ruby-kafka-0.6.3
- old
+ new
@@ -23,10 +23,11 @@
GROUP_COORDINATOR_API = 10
JOIN_GROUP_API = 11
HEARTBEAT_API = 12
LEAVE_GROUP_API = 13
SYNC_GROUP_API = 14
+ DESCRIBE_GROUPS_API = 15
LIST_GROUPS_API = 16
SASL_HANDSHAKE_API = 17
API_VERSIONS_API = 18
CREATE_TOPICS_API = 19
DELETE_TOPICS_API = 20
@@ -178,5 +179,7 @@
require "kafka/protocol/alter_configs_response"
require "kafka/protocol/create_partitions_request"
require "kafka/protocol/create_partitions_response"
require "kafka/protocol/list_groups_request"
require "kafka/protocol/list_groups_response"
+require "kafka/protocol/describe_groups_request"
+require "kafka/protocol/describe_groups_response"