co.cask.cdap.notifications.service.kafka

Class KafkaMessageCodec

java.lang.Object

co.cask.cdap.notifications.service.kafka.KafkaMessageCodec

public final class KafkaMessageCodec
extends Object

Encoder/decoder of Notifications to Kafka messages.

Method Summary

Methods

Modifier and Type	Method and Description
static co.cask.cdap.notifications.service.kafka.KafkaMessage	decode(ByteBuffer byteBuffer)
static ByteBuffer	encode(co.cask.cdap.notifications.service.kafka.KafkaMessage message)

Methods inherited from class java.lang.Object

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

Method Detail

encode

public static ByteBuffer encode(co.cask.cdap.notifications.service.kafka.KafkaMessage message)
                         throws IOException

Throws:

IOException

decode

public static co.cask.cdap.notifications.service.kafka.KafkaMessage decode(ByteBuffer byteBuffer)
                                                                    throws IOException

Throws:

IOException