org.nuxeo.lib.stream.log.kafka

Class KafkaNamespace

java.lang.Object

org.nuxeo.lib.stream.log.kafka.KafkaNamespace

public class KafkaNamespace
extends Object

Handle a namespace for Kafka topic and group.

Since:

10.1

Field Summary

Fields

Modifier and Type	Field and Description
protected String	prefix
protected int	prefixLen

Constructor Summary

Constructors

Constructor and Description
KafkaNamespace(String prefix)

Method Summary

Modifier and Type	Method and Description
String	getGroup(String kafkaGroup)
String	getKafkaGroup(String group)
String	getLogName(String topicName)
String	getTopicName(String logName)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

prefix

protected final String prefix

prefixLen

protected final int prefixLen

Constructor Detail

KafkaNamespace

public KafkaNamespace(String prefix)

Method Detail

getTopicName

public String getTopicName(String logName)

getLogName

public String getLogName(String topicName)

getKafkaGroup

public String getKafkaGroup(String group)

getGroup

public String getGroup(String kafkaGroup)

toString

public String toString()

Overrides:

toString in class Object