Http
fun KafkaRest.Companion.Http(credentials: Credentials, baseUri: Uri, http: HttpHandler = JavaHttpClient()): KafkaRest
Standard HTTP implementation of KafkaRest Proxy
fun KafkaRestConsumer.Companion.Http(credentials: Credentials, baseUri: Uri, http: HttpHandler = JavaHttpClient()): KafkaRestConsumer
Standard HTTP implementation of KafkaRestConsumer
fun KafkaRestConsumer.Companion.Http(credentials: Credentials, group: ConsumerGroup, consumer: Consumer, baseUri: Uri, http: HttpHandler = JavaHttpClient()): Result<KafkaRestConsumer, Nothing>
Convenience function to create a consumer