Skip to content

Commit 1e0ad09

Browse files
committed
error debug
1 parent 6688307 commit 1e0ad09

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

examples/kafkajs/admin/describe-groups.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ async function adminStart() {
7272
console.log(`\tProtocol type: ${group.protocolType}`);
7373
console.log(`\tPartition assignor: ${group.partitionAssignor}`);
7474
console.log(`\tState: ${group.state}`);
75+
console.log(`\tType: ${group.type}`);
7576
console.log(`\tCoordinator: ${group.coordinator ? group.coordinator.id : group.coordinator}`);
7677
printNode(group.coordinator, '\t');
7778
console.log(`\tAuthorized operations: ${group.authorizedOperations}`);

src/common.cc

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1127,8 +1127,7 @@ v8::Local<v8::Object> FromConsumerGroupDescription(
11271127

11281128
// type
11291129
Nan::Set(returnObject, Nan::New("type").ToLocalChecked(),
1130-
Nan::New<v8::String>(rd_kafka_ConsumerGroupDescription_type(desc))
1131-
.ToLocalChecked());
1130+
Nan::New<v8::Number>(rd_kafka_ConsumerGroupDescription_type(desc)));
11321131

11331132
// coordinator
11341133
const rd_kafka_Node_t* coordinator =

0 commit comments

Comments
 (0)