Package com.helix.core.stream.kafka

package com.helix.core.stream.kafka

Class	Description
CommitMode	Offset commitment modes for Kafka partition consumer streams.
KafkaEventCodec	Serializer and deserializer for Kafka stream records, rule events, and execution results.
KafkaRuleStreamConsumer	Enterprise clustered Kafka stream consumer supporting partition-level parallelism, virtual thread fan-out, dynamic rebalance listeners, and backpressure control via pause/resume.
KafkaRuleStreamConsumer.RecordEvaluator
KafkaRuleStreamProducer	High-performance Kafka producer for streaming rule events and structured evaluation results.
KafkaStreamConfig	Configuration for clustered Kafka rule streaming ingestion and result publishing.
KafkaStreamConfig.Builder
KafkaStreamEngine	Enterprise clustered Kafka streaming engine implementing StreamBridge.