import { Consumer, type Message, MessagesStream } from '@platformatic/kafka';
import { ComponentBase } from '@syncbridge/common';
import { TcpClientComponent } from '@syncbridge/net';
import { KafkaSaslVariables } from './kafka-client.variables.js';
import { KafkaConsumerVariables } from './kafka-consumer.variables.js';
/**
 * KafkaConsumer component
 */
export declare class KafkaConsumerComponent<TEvents extends KafkaConsumerComponent.Events = KafkaConsumerComponent.Events> extends ComponentBase<TEvents> {
    protected _stopping?: boolean;
    consumer: Consumer;
    stream: MessagesStream<any, any, any, any>;
    values: KafkaConsumerVariables;
    protected _init(): Promise<void>;
    protected _start(abortSignal: AbortSignal): Promise<void>;
    protected _stop(): Promise<void>;
    protected _terminate(): Promise<void>;
    protected _configureConsumer(): Promise<void>;
    protected _startConsumer(): Promise<void>;
    protected _onMessage(message: Message<any, any, any, any>): Promise<void>;
}
/**
 * @namespace
 */
export declare namespace KafkaConsumerComponent {
    interface Events extends ComponentBase.Events {
        message: [msg: Message<any, any, any, any>];
    }
    const Variables: typeof KafkaConsumerVariables;
    type Variables = KafkaConsumerVariables;
    const SaslVariables: typeof KafkaSaslVariables;
    type SaslVariables = KafkaSaslVariables;
    const TlsVariables: typeof TcpClientComponent.TlsVariables;
    type TlsVariables = TcpClientComponent.TlsVariables;
}