toggle menu
http4k
6.9.0.0
jvm
switch theme
search in API
http4k-connect-kafka-rest-fake
/
org.http4k.connect.kafka.rest
/
FakeKafkaRest
/
FakeKafkaRest
Fake
Kafka
Rest
constructor
(
consumers
:
Storage
<
ConsumerState
>
=
Storage.InMemory()
,
topics
:
Storage
<
List
<
SendRecord
>
>
=
Storage.InMemory()
,
baseUri
:
Uri
=
Uri.of("http://localhost:${FakeKafkaRest::class.defaultPort}")
)