import { Producer } from "node-rdkafka";
import { SchemaRegistry } from "@kafkajs/confluent-schema-registry";
import { ConfigService } from "@nestjs/config";
import { Observable } from "rxjs";
export declare class KafkaService {
    private configService;
    constructor(configService: ConfigService);
    schemaIds: Record<string, Promise<number>>;
    getKafkaConfig: () => {
        "metadata.broker.list": any;
    };
    private removeBranchObjects;
    getKafkaProducer(): Promise<Producer>;
    getSchemaId(topicName: string, avdlPath: string, options?: {
        isKey?: boolean;
    }): Promise<number>;
    schemaRegistry: SchemaRegistry;
    getKafkaRegistry(): SchemaRegistry;
    produceKafkaMessage<T extends {
        id: string;
    }>(topic: string, messageValue: T, avdlPath: string, messageKey?: {
        id: string;
    }, avdlKeyPath?: string): Promise<boolean>;
    getReadStream<Value, Key = {
        id: string;
    }>(topic: string, groupId?: string, autoOffsetRest?: "smallest" | "earliest" | "beginning" | "largest" | "latest" | "end" | "error"): Observable<{
        value: Value;
        key: Key;
    }>;
}
//# sourceMappingURL=kafka.service.d.ts.map