import { ConsumerSubscribeTopics, ConsumerConfig } from 'kafkajs';
export type KafkaConsumerOptions = {
    subscribe: ConsumerSubscribeTopics;
    consumerConfig: ConsumerConfig;
};
export declare const KafkaConsumer: (options: KafkaConsumerOptions) => MethodDecorator;
export declare function KafkaProcessor(): ClassDecorator;