import { Cluster, GroupMember, GroupMemberAssignment, GroupState } from 'kafkajs'; export declare class KafkaPartitionAssigner { private readonly clientKafka; private readonly config; constructor(clientKafka: object, config: { cluster: Cluster; }); private get name(); private get version(); assign(group: { members: Array; topics: Array; }): Array; protocol(subscription: { topics: Array; userData: Buffer; }): GroupState; private decodeMember; private getMembersData; private fillPreviousAssignments; private createTopicPartitionList; private initializeAndReassignTopicPartitions; private assignPartitionsToMembers; private insertAssignmentsByTopic; private getPreviousAssignment; }