toggle menu
kaskad_platform
1.0.0
jvm
switch theme
search in API
broker
/
ru.sydis.broker.implementations
/
KafkaMessageBroker
/
subscribeWithFilterOld
subscribe
With
Filter
Old
open
override
fun
subscribeWithFilterOld
(
topic
:
String
,
filter
:
(
K
?
,
V
)
->
Boolean
,
onReceive
:
(
t
:
String
,
List
<
Pair
<
K
?
,
V
>
>
)
->
Unit
)