FakeKafkaRest

class FakeKafkaRest(val consumers: Storage<ConsumerState> = Storage.InMemory(), val topics: Storage<List<SendRecord>> = Storage.InMemory(), baseUri: Uri = Uri.of("http://localhost:${FakeKafkaRest::class.defaultPort}")) : ChaoticHttpHandler

Constructors

Link copied to clipboard
constructor(consumers: Storage<ConsumerState> = Storage.InMemory(), topics: Storage<List<SendRecord>> = Storage.InMemory(), baseUri: Uri = Uri.of("http://localhost:${FakeKafkaRest::class.defaultPort}"))

Properties

Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
Link copied to clipboard

Convenience function to get a FakeKafkaRest client

Link copied to clipboard
open operator override fun invoke(request: Request): Response
Link copied to clipboard
Link copied to clipboard