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

Package-level declarations

Types

Link copied to clipboard
fun interface Partitioner<K, V> : Function2<K, V, PartitionId?>

Responsible for selecting a partition for a particular record

Link copied to clipboard
fun interface RecordConsumer<T : Any> : Function1<T, Result4k<Unit, Exception>>

Helper to enable processing of Records.

Functions

Link copied to clipboard
fun <K, V> NoOpPartitioner(partitions: List<PartitionId>): Partitioner<K, V>

Always selects no partition as a strategy

Link copied to clipboard
fun <K, V> RoundRobinRecordPartitioner(partitions: List<PartitionId>): Partitioner<K, V>

fun <K, V> RoundRobinRecordPartitioner(partitions: List<PartitionId>, seed: Random): Partitioner<K, V>

Round robins from the list of partitions, starting at a random place in the list

Link copied to clipboard
fun <K, V> StickyKeyRecordPartitioner(partitions: List<PartitionId>): Partitioner<K, V>

Uses the key hash to get the partition