whylogs-container
1.0-SNAPSHOT
whylogs-container
/
ai.whylabs.services.whylogs.kafka
/
KotlinConsumer
/
Companion
/
consumer
consumer
inline
fun
<
K
,
V
>
consumer
(
config
:
KotlinConsumerConfig
<
K
,
V
>
,
noinline
processor
:
suspend
(
record
:
KafkaRecord
<
K
,
V
>
)
->
Boolean
)
:
KotlinConsumer
<
K
,
V
>
Content copied to clipboard