amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Formatting and general fixes for tests.

Browse Source
This commit is contained in:
Michael Kaufman
2019-08-19 15:48:16 -04:00
parent c376018dc9
commit 4480a7c3a1
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
integration/microservices/src/kafka/kafka.controller.ts
View File

@@ -85,7 +85,7 @@ export class KafkaController implements OnModuleInit {
}),
}).toPromise();
await Bluebird.delay(30000);
// await Bluebird.delay(30000);
// this.logger.error(util.format('@Query math.sum result %o', result));

4
packages/microservices/client/client-kafka.ts
View File

@@ -206,7 +206,7 @@ export class ClientKafka extends ClientProxy {
}, this.options.send || {}));
}
private getReplyPartition(topic: string): number {
private getReplyPartition(topic: string): string {
// this.consumer.describeGroup().then((description) => {
// // this.logger.error(util.format('getReplyTopicPartition(): groupDescription: %o', description));
@@ -235,7 +235,7 @@ export class ClientKafka extends ClientProxy {
throw new Error(`Unable to send the message request because the client consumer subscribed to the topic (${topic}) is not assigned any partitions.`);
}
return topicAssignments[0];
return topicAssignments[0].toString();
}
protected publish(