export interface KafkaConsumerOptions {
    name?: string;
    groupId?: string;
}