partitionOf

open suspend override fun partitionOf(topic: String, key: String): Int