import { Consumer, ConsumerConfig, Kafka, Producer, ProducerConfig } from 'kafkajs'; import { KafkaModuleOptions } from './interface/kafka-module-options.interface'; export declare class KafkaService { private readonly options; kafka: Kafka; constructor(options: KafkaModuleOptions); producer(config?: ProducerConfig): Producer; consumer(config: ConsumerConfig): Consumer; }