import { KafkaMessage, IHeaders } from 'kafkajs';
import { IAction } from './types';
export declare function transformKafkaMessageToAction<Payload>(topic: string, message: KafkaMessage, headerParser?: (h: IHeaders | undefined) => Record<string, string>, valueParser?: (val: string) => any): IAction<Payload>;