if (!Kafka[className]) {
            this.log.warn(`Strategy ${className} not found. Using default.`);
            return new Kafka.DefaultAssignmentStrategy();
        }