import { type CallbackWithPromise } from '../../apis/callbacks.ts';
import { type FetchResponse } from '../../apis/consumer/fetch-v17.ts';
import { type ConnectionPool } from '../../network/connection-pool.ts';
import { Base, type BaseEvents, kCreateConnectionPool } from '../base/base.ts';
import { MessagesStream } from './messages-stream.ts';
import { TopicsMap } from './topics-map.ts';
import { type CommitOptions, type ConsumeOptions, type ConsumerGroupJoinPayload, type ConsumerGroupLeavePayload, type ConsumerGroupRebalancePayload, type ConsumerHeartbeatErrorPayload, type ConsumerHeartbeatPayload, type ConsumerOptions, type FetchOptions, type GetLagOptions, type GroupAssignment, type GroupOptions, type ListCommitsOptions, type ListOffsetsOptions, type Offsets, type OffsetsWithTimestamps } from './types.ts';
export interface ConsumerEvents extends BaseEvents {
    'consumer:group:join': (payload: ConsumerGroupJoinPayload) => void;
    'consumer:group:leave': (payload: ConsumerGroupLeavePayload) => void;
    'consumer:group:rejoin': () => void;
    'consumer:group:rebalance': (payload: ConsumerGroupRebalancePayload) => void;
    'consumer:heartbeat:start': (payload?: ConsumerHeartbeatPayload) => void;
    'consumer:heartbeat:cancel': (payload: ConsumerHeartbeatPayload) => void;
    'consumer:heartbeat:end': (payload?: ConsumerHeartbeatPayload) => void;
    'consumer:heartbeat:error': (payload: ConsumerHeartbeatErrorPayload) => void;
    'consumer:lag': (lag: Offsets) => void;
    'consumer:lag:error': (error: Error) => void;
}
export declare class Consumer<Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderValue = Buffer> extends Base<ConsumerOptions<Key, Value, HeaderKey, HeaderValue>, ConsumerEvents> {
    #private;
    groupId: string;
    groupInstanceId: string | null;
    generationId: number;
    memberId: string | null;
    topics: TopicsMap;
    assignments: GroupAssignment[] | null;
    constructor(options: ConsumerOptions<Key, Value, HeaderKey, HeaderValue>);
    get streamsCount(): number;
    get lastHeartbeat(): Date | null;
    get coordinatorId(): number | null;
    get streamContext(): unknown;
    close(force: boolean | CallbackWithPromise<void>, callback?: CallbackWithPromise<void>): void;
    close(force?: boolean): Promise<void>;
    isActive(): boolean;
    consume(options: ConsumeOptions<Key, Value, HeaderKey, HeaderValue>, callback: CallbackWithPromise<MessagesStream<Key, Value, HeaderKey, HeaderValue>>): void;
    consume(options: ConsumeOptions<Key, Value, HeaderKey, HeaderValue>): Promise<MessagesStream<Key, Value, HeaderKey, HeaderValue>>;
    fetch(options: FetchOptions<Key, Value, HeaderKey, HeaderValue>, callback: CallbackWithPromise<FetchResponse>): void;
    fetch(options: FetchOptions<Key, Value, HeaderKey, HeaderValue>): Promise<FetchResponse>;
    commit(options: CommitOptions, callback: CallbackWithPromise<void>): void;
    commit(options: CommitOptions): Promise<void>;
    listOffsets(options: ListOffsetsOptions, callback: CallbackWithPromise<Offsets>): void;
    listOffsets(options: ListOffsetsOptions): Promise<Offsets>;
    listOffsetsWithTimestamps(options: ListOffsetsOptions, callback: CallbackWithPromise<OffsetsWithTimestamps>): void;
    listOffsetsWithTimestamps(options: ListOffsetsOptions): Promise<OffsetsWithTimestamps>;
    listCommittedOffsets(options: ListCommitsOptions, callback: CallbackWithPromise<Offsets>): void;
    listCommittedOffsets(options: ListCommitsOptions): Promise<Offsets>;
    getLag(options: GetLagOptions, callback: CallbackWithPromise<Offsets>): void;
    getLag(options: GetLagOptions): Promise<Offsets>;
    startLagMonitoring(options: GetLagOptions, interval: number): void;
    stopLagMonitoring(): void;
    findGroupCoordinator(callback: CallbackWithPromise<number>): void;
    findGroupCoordinator(): Promise<number>;
    [kCreateConnectionPool](context?: unknown): ConnectionPool;
    joinGroup(options: GroupOptions, callback: CallbackWithPromise<string>): void;
    joinGroup(options?: GroupOptions): Promise<string>;
    leaveGroup(force?: boolean | CallbackWithPromise<void>, callback?: CallbackWithPromise<void>): void;
    leaveGroup(force?: boolean): Promise<void>;
}