|
9 | 9 | createAdmin,
|
10 | 10 | sleep,
|
11 | 11 | } = require('../testhelpers');
|
12 |
| -const { ConsumerGroupStates, ErrorCodes, AclOperationTypes } = require('../../../lib').KafkaJS; |
| 12 | +const { ConsumerGroupStates, ConsumerGroupTypes, ErrorCodes, AclOperationTypes } = require('../../../lib').KafkaJS; |
13 | 13 |
|
14 | 14 | describe('Admin > describeGroups', () => {
|
15 | 15 | let topicName, groupId, consumer, admin, groupInstanceId, producer;
|
@@ -86,6 +86,7 @@ describe('Admin > describeGroups', () => {
|
86 | 86 | isSimpleConsumerGroup: false,
|
87 | 87 | protocolType: 'consumer',
|
88 | 88 | state: ConsumerGroupStates.STABLE,
|
| 89 | + type: ConsumerGroupTypes.CLASSIC, |
89 | 90 | coordinator: expect.objectContaining({
|
90 | 91 | id: expect.any(Number),
|
91 | 92 | host: expect.any(String),
|
@@ -137,6 +138,7 @@ describe('Admin > describeGroups', () => {
|
137 | 138 | protocol: '',
|
138 | 139 | partitionAssignor: '',
|
139 | 140 | state: ConsumerGroupStates.EMPTY,
|
| 141 | + type: ConsumerGroupTypes.CLASSIC, |
140 | 142 | protocolType: 'consumer',
|
141 | 143 | isSimpleConsumerGroup: false,
|
142 | 144 | coordinator: expect.objectContaining({
|
|
0 commit comments