lib/kafka/cluster.rb in ruby-kafka-0.6.2 vs lib/kafka/cluster.rb in ruby-kafka-0.6.3

@@ -253,9 +253,16 @@
       end
 
       nil
     end
 
+    def describe_group(group_id)
+      response = get_group_coordinator(group_id: group_id).describe_groups(group_ids: [group_id])
+      group = response.groups.first
+      Protocol.handle_error(group.error_code)
+      group
+    end
+
     def create_partitions_for(name, num_partitions:, timeout:)
       options = {
         topics: [[name, num_partitions, nil]],
         timeout: timeout
       }