We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 84961d4 commit ad44931Copy full SHA for ad44931
1 file changed
integration/microservices/src/kafka/kafka.controller.ts
@@ -11,7 +11,6 @@ import { Logger } from '@nestjs/common/services/logger.service';
11
import * as util from 'util';
12
13
import { Observable } from 'rxjs';
14
-import * as uuid from 'uuid';
15
import * as Bluebird from 'bluebird';
16
17
@Controller()
@@ -41,8 +40,6 @@ export class KafkaController implements OnModuleInit {
41
40
@Query('command') cmd,
42
@Body() data: number[],
43
): Promise<Observable<any>> {
44
- const key = uuid.v4(); // stick to a single partition
45
-
46
const result = await this.client.send('math.sum', {
47
key: '1',
48
value: {
0 commit comments