import { Readable } from "node:stream";
import type { ClientConfigOrString } from "../client/client.type.js";
import type { Id } from '../wire/identifier.utils.js';
import { type PollingStrategy } from "../wire/index.js";
export type ConsumerStreamRequest = {
    streamId: Id;
    topicId: Id;
    pollingStrategy: PollingStrategy;
    count: number;
    interval?: number;
    autocommit?: boolean;
    endOnLastOffset?: boolean;
};
export type SingleConsumerStreamRequest = ConsumerStreamRequest & {
    partitionId: number;
};
export type GroupConsumerStreamRequest = ConsumerStreamRequest & {
    groupName: string;
};
export declare const singleConsumerStream: (config: ClientConfigOrString) => ({ streamId, topicId, partitionId, pollingStrategy, count, interval, autocommit, endOnLastOffset }: SingleConsumerStreamRequest) => Promise<Readable>;
export declare const groupConsumerStream: (config: ClientConfigOrString) => ({ groupName, streamId, topicId, pollingStrategy, count, interval, autocommit, endOnLastOffset }: GroupConsumerStreamRequest) => Promise<Readable>;
//# sourceMappingURL=consumer-stream.d.ts.map