import { KafkaConfig, Mechanism, SASLOptions } from "kafkajs";
import { KafkaConsumerOffsetReset } from "../enums";
export interface KafkaConsumerConfig extends Omit<KafkaConfig, "ssl" | "sasl" | "brokers" | "clientId" | "offsetReset" | "topicsPartition"> {
    bootstrapServer: string | string[];
    groupId: string;
    clientId?: string;
    offsetReset?: KafkaConsumerOffsetReset;
    topicsPartition?: {
        topic: string;
        partition: number;
    }[];
    ssl?: boolean;
    sasl?: SASLOptions | Mechanism | undefined;
}