http4k-connect-kafka-rest/org.http4k.connect.kafka.rest.extensions/Partitioner

Partitioner

fun interface Partitioner<K, V> : Function2<K, V, PartitionId?>

Responsible for selecting a partition for a particular record

Functions

Link copied to clipboard
abstract operator fun invoke(p1: K, p2: V): PartitionId?