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

Package-level declarations

Functions

fun commitOffsets(consumers: Storage<ConsumerState>): RoutingHttpHandler

fun consumeRecords(consumers: Storage<ConsumerState>, topics: Storage<List<SendRecord>>): RoutingHttpHandler

fun createConsumer(consumers: Storage<ConsumerState>, baseUri: Uri): RoutingHttpHandler

fun deleteConsumer(consumers: Storage<ConsumerState>): RoutingHttpHandler

fun getOffsets(consumers: Storage<ConsumerState>): RoutingHttpHandler

fun getPartitions(): RoutingHttpHandler

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

fun seekOffsets(consumers: Storage<ConsumerState>): RoutingHttpHandler

subscribeToTopics

fun subscribeToTopics(consumers: Storage<ConsumerState>): RoutingHttpHandler