Uses of Interface com.helix.core.stream.kafka.KafkaRuleStreamConsumer.RecordEvaluator (Helix - Parent 1.0.0-SNAPSHOT API)

Packages that use KafkaRuleStreamConsumer.RecordEvaluator

Package

Description

com.helix.core.stream.kafka

Uses of KafkaRuleStreamConsumer.RecordEvaluator in com.helix.core.stream.kafka

Constructors in com.helix.core.stream.kafka with parameters of type KafkaRuleStreamConsumer.RecordEvaluator

Modifier

Constructor

Description

KafkaRuleStreamConsumer(KafkaStreamConfig config, KafkaRuleStreamConsumer.RecordEvaluator evaluator)

KafkaRuleStreamConsumer(KafkaStreamConfig config, org.apache.kafka.clients.consumer.Consumer<String,byte[]> consumer, KafkaRuleStreamConsumer.RecordEvaluator evaluator)