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