http4k-connect-kafka-rest-fake/org.http4k.connect.kafka.rest.v3.endpoints

Package-level declarations

Properties

val clusterId: BiDiPathLens<ClusterId>

val topic: BiDiPathLens<Topic>

Functions

fun getPartitions(baseUrl: Uri): RoutingHttpHandler

fun getTopic(baseUrl: Uri): RoutingHttpHandler

fun getTopics(baseUrl: Uri, topics: Storage<List<SendRecord>>): RoutingHttpHandler

fun produceRecords(topics: Storage<List<SendRecord>>): RoutingHttpHandler