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