@@ -10,7 +10,7 @@ const {
10
10
createAdmin,
11
11
sleep,
12
12
} = require ( '../testhelpers' ) ;
13
- const { ConsumerGroupStates, ErrorCodes, AclOperationTypes } = require ( '../../../lib' ) . KafkaJS ;
13
+ const { ConsumerGroupStates, ConsumerGroupTypes , ErrorCodes, AclOperationTypes } = require ( '../../../lib' ) . KafkaJS ;
14
14
15
15
describe ( 'Admin > describeGroups' , ( ) => {
16
16
let topicName , groupId , consumer , admin , groupInstanceId , producer ;
@@ -90,6 +90,7 @@ describe('Admin > describeGroups', () => {
90
90
isSimpleConsumerGroup : false ,
91
91
protocolType : 'consumer' ,
92
92
state : ConsumerGroupStates . STABLE ,
93
+ type : ConsumerGroupTypes . CLASSIC ,
93
94
coordinator : expect . objectContaining ( {
94
95
id : expect . any ( Number ) ,
95
96
host : expect . any ( String ) ,
@@ -141,6 +142,7 @@ describe('Admin > describeGroups', () => {
141
142
protocol : expect . any ( String ) ,
142
143
partitionAssignor : expect . any ( String ) ,
143
144
state : ConsumerGroupStates . EMPTY ,
145
+ type : ConsumerGroupTypes . CLASSIC ,
144
146
protocolType : 'consumer' ,
145
147
isSimpleConsumerGroup : false ,
146
148
coordinator : expect . objectContaining ( {
0 commit comments