http4k-connect-kafka-rest/org.http4k.connect.kafka.rest

Package-level declarations

Types

Link copied to clipboard
object GenericContainerAdapter : JsonAdapter<GenericContainer>
Link copied to clipboard
interface KafkaRest

Docs: https://docs.confluent.io/platform/current/kafka-rest/

Link copied to clipboard
interface KafkaRestConsumer
Link copied to clipboard
@KotshiJsonAdapterFactory
object KafkaRestJsonAdapterFactory : JsonAdapter.Factory
Link copied to clipboard
Link copied to clipboard
class RecordDataJsonAdapter(moshi: Moshi) : JsonAdapter<RecordData<*>>
Link copied to clipboard
class RecordsJsonAdapter(moshi: Moshi) : JsonAdapter<Records>

Functions

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