Package com.helix.core.stream.kafka

Class KafkaRuleStreamConsumer

java.lang.Object

com.helix.core.stream.kafka.KafkaRuleStreamConsumer

All Implemented Interfaces:

AutoCloseable

public class KafkaRuleStreamConsumer
extends Object
implements AutoCloseable

Enterprise clustered Kafka stream consumer supporting partition-level parallelism, virtual thread fan-out, dynamic rebalance listeners, and backpressure control via pause/resume.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	KafkaRuleStreamConsumer.RecordEvaluator

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
Set<org.apache.kafka.common.TopicPartition>	getActivePartitions()
org.apache.kafka.clients.consumer.Consumer<String,byte[]>	getConsumer()
Set<org.apache.kafka.common.TopicPartition>	getPausedPartitions()
long	getTotalCompleted()
long	getTotalPolled()
void	start()
void	subscribe(Collection<String> topics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaRuleStreamConsumer

public KafkaRuleStreamConsumer(KafkaStreamConfig config,
 KafkaRuleStreamConsumer.RecordEvaluator evaluator)

KafkaRuleStreamConsumer

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

Method Details

start

public void start()

subscribe

public void subscribe(Collection<String> topics)

close

public void close()

Specified by:

close in interface AutoCloseable

getPausedPartitions

public Set<org.apache.kafka.common.TopicPartition> getPausedPartitions()

getActivePartitions

public Set<org.apache.kafka.common.TopicPartition> getActivePartitions()

getTotalPolled

public long getTotalPolled()

getTotalCompleted

public long getTotalCompleted()

getConsumer

public org.apache.kafka.clients.consumer.Consumer<String,byte[]> getConsumer()