import { KafkaMessage } from '../external/kafka.interface';
import { BaseRpcContext } from './base-rpc.context';
declare type KafkaContextArgs = [KafkaMessage, number, string];
export declare class KafkaContext extends BaseRpcContext<KafkaContextArgs> {
constructor(args: KafkaContextArgs);
/**
* Returns the reference to the original message.
*/
getMessage(): KafkaMessage;
/**
* Returns the partition.
*/
getPartition(): number;
/**
* Returns the name of the topic.
*/
getTopic(): string;
}
export {};