import { DynamicModule } from '@nestjs/common'; import type { TransportModuleAsyncConfigOptions } from './domain/interfaces'; export declare class TransportConfigModule { /** * Kafka-based Transport configuration module. * * Registers a Kafka client and exposes a high-level transport service via the `CLIENT_TRANSPORT` token. * This allows emitting and sending events through Kafka using a consistent interface (`TransportServicePort`). * * Usage: * ```ts * @Injectable() * export class ExampleService { * constructor( * @Inject(CLIENT_TRANSPORT) private readonly transport: TransportServicePort * ) {} * } * ``` * * @param options.brokers Required. Kafka broker addresses. * @param options.clientId Required. Kafka client ID. * @param options.groupId Required. Kafka consumer group ID. * @param options.ssl Optional. Use SSL. Defaults to false. * @param options.sasl Optional. SASL auth config (username, password, mechanism). * @param options.allowAutoTopicCreation Optional. Defaults to false. * @param options.isGlobal Optional. Whether to register the module globally. Defaults to false. * @returns A dynamic module that provides `CLIENT_TRANSPORT` (as `TransportServicePort`). */ static configAsync(options: TransportModuleAsyncConfigOptions): DynamicModule; } //# sourceMappingURL=transport.module.d.ts.map