import type { CommandResponse } from '../../client/client.type.js'; import { type Id } from '../identifier.utils.js'; import { type ConsumerGroup } from './group.utils.js'; /** * Parameters for the create consumer group command. */ export type CreateGroup = { /** Stream identifier (ID or name) */ streamId: Id; /** Topic identifier (ID or name) */ topicId: Id; /** Consumer group name (1-255 bytes) */ name: string; }; /** * Create consumer group command definition. * Creates a new consumer group within a topic. */ export declare const CREATE_GROUP: { code: number; serialize: ({ streamId, topicId, name }: CreateGroup) => Buffer; deserialize: (r: CommandResponse) => ConsumerGroup; }; /** * Executable create consumer group command function. */ export declare const createGroup: (getClient: import("../../client/client.type.js").ClientProvider) => (arg: CreateGroup) => Promise; //# sourceMappingURL=create-group.command.d.ts.map