co.cask.cdap.notifications.service.kafka

Class KafkaNotificationUtils

java.lang.Object

co.cask.cdap.notifications.service.kafka.KafkaNotificationUtils

public final class KafkaNotificationUtils
extends Object

Util methods for using Notifications with Kafka.

Method Summary

Methods

Modifier and Type	Method and Description
static TopicPartition	getKafkaTopicPartition(String topic, Id.NotificationFeed feed) Map a Id.NotificationFeed to a Kafka topic partition.
static Id.NotificationFeed	getMessageFeed(String messageKey) Return the Id.NotificationFeed attached to a Kafka message containing a notification.
static String	getMessageKey(Id.NotificationFeed feed) Build the key of a Kafka message based on a feed.

Methods inherited from class java.lang.Object

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

Method Detail

getKafkaTopicPartition

public static TopicPartition getKafkaTopicPartition(String topic,
                                    Id.NotificationFeed feed)

Map a Id.NotificationFeed to a Kafka topic partition.

Parameters:

feed - Id.NotificationFeed object

topic - kafka topic

Returns:

Kafka topic that should contain the Notifications published on the feed

getMessageKey

public static String getMessageKey(Id.NotificationFeed feed)

Build the key of a Kafka message based on a feed.

Parameters:

feed - Id.NotificationFeed to get the Kafka message key of

Returns:

the key of a Kafka message based on the feed

getMessageFeed

public static Id.NotificationFeed getMessageFeed(String messageKey)

Return the Id.NotificationFeed attached to a Kafka message containing a notification.

Parameters:

messageKey - key of a Kafka message containing a Notification

Returns:

the Id.NotificationFeed attached to a Kafka message containing a notification