1 | import { KafkaMessage } from '../external/kafka.interface';
|
2 | import { BaseRpcContext } from './base-rpc.context';
|
3 | declare type KafkaContextArgs = [KafkaMessage, number, string];
|
4 | export declare class KafkaContext extends BaseRpcContext<KafkaContextArgs> {
|
5 | constructor(args: KafkaContextArgs);
|
6 | /**
|
7 | * Returns the reference to the original message.
|
8 | */
|
9 | getMessage(): KafkaMessage;
|
10 | /**
|
11 | * Returns the partition.
|
12 | */
|
13 | getPartition(): number;
|
14 | /**
|
15 | * Returns the name of the topic.
|
16 | */
|
17 | getTopic(): string;
|
18 | }
|
19 | export {};
|