org.nuxeo.runtime.kafka

Class KafkaConfigDescriptor

java.lang.Object

org.nuxeo.runtime.kafka.KafkaConfigDescriptor

public class KafkaConfigDescriptor
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaConfigDescriptor.ConsumerProperties
static class	KafkaConfigDescriptor.ProducerProperties

Field Summary

Fields

Modifier and Type	Field and Description
protected KafkaConfigDescriptor.ConsumerProperties	consumerProperties
String	name
protected KafkaConfigDescriptor.ProducerProperties	producerProperties
Boolean	randomPrefix
String	topicPrefix
String	zkServers

Constructor Summary

Constructors

Constructor and Description
KafkaConfigDescriptor()

Method Summary

Modifier and Type	Method and Description
Properties	getConsumerProperties()
Properties	getProducerProperties()
String	getTopicPrefix()

Methods inherited from class java.lang.Object

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

Field Detail

name

public String name

zkServers

public String zkServers

topicPrefix

public String topicPrefix

randomPrefix

public Boolean randomPrefix

producerProperties

protected KafkaConfigDescriptor.ProducerProperties producerProperties

consumerProperties

protected KafkaConfigDescriptor.ConsumerProperties consumerProperties

Constructor Detail

KafkaConfigDescriptor

public KafkaConfigDescriptor()

Method Detail

getProducerProperties

public Properties getProducerProperties()

getConsumerProperties

public Properties getConsumerProperties()

getTopicPrefix

public String getTopicPrefix()