whylogs-container
1.0-SNAPSHOT
whylogs-container
/
ai.whylabs.services.whylogs.kafka
/
KotlinConsumer
/
KotlinConsumer
Kotlin
Consumer
fun
<
K
,
V
>
KotlinConsumer
(
config
:
KotlinConsumerConfig
<
K
,
V
>
,
valueType
:
TypeReference
<
V
>
,
keyType
:
TypeReference
<
K
>
,
process
:
suspend
(
record
:
KafkaRecord
<
K
,
V
>
)
->
Boolean
)
Content copied to clipboard