Companion
object Companion
Functions
Link copied to clipboard
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