Package com.helix.core.stream.kafka

Class KafkaEventCodec

java.lang.Object

com.helix.core.stream.kafka.KafkaEventCodec

public class KafkaEventCodec
extends Object

Serializer and deserializer for Kafka stream records, rule events, and execution results.

Constructor Summary

Constructors

Constructor	Description
KafkaEventCodec()

Method Summary

Modifier and Type	Method	Description
static RuleEvent	deserializeEvent(String topic, String key, byte[] payload, org.apache.kafka.common.header.Headers headers)
static StreamResult	deserializeResult(byte[] data)
static byte[]	serializeEvent(RuleEvent event)
static byte[]	serializeResult(StreamResult result)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaEventCodec

public KafkaEventCodec()

Method Details

serializeResult

public static byte[] serializeResult(StreamResult result)

deserializeResult

public static StreamResult deserializeResult(byte[] data)

serializeEvent

public static byte[] serializeEvent(RuleEvent event)

deserializeEvent

public static RuleEvent deserializeEvent(String topic,
 String key,
 byte[] payload,
 org.apache.kafka.common.header.Headers headers)