Package org.nuxeo.runtime.kafka

Class KafkaConfigDescriptor

java.lang.Object

org.nuxeo.runtime.kafka.KafkaConfigDescriptor

All Implemented Interfaces:

Descriptor

public class KafkaConfigDescriptor
extends Object
implements Descriptor

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
KafkaConfigDescriptor.AdminProperties	adminProperties
KafkaConfigDescriptor.ConsumerProperties	consumerProperties
String	copy
String	name
KafkaConfigDescriptor.ProducerProperties	producerProperties
Boolean	randomPrefix
String	topicPrefix
String	zkServers	Deprecated.

Fields inherited from interface org.nuxeo.runtime.model.Descriptor

UNIQUE_DESCRIPTOR_ID

Constructor Summary

Constructors

Constructor	Description
KafkaConfigDescriptor()

Method Summary

Modifier and Type	Method	Description
String	getId()	The descriptor id, descriptors with same id are merged.
void	init(KafkaConfigDescriptor source)
protected Properties	mergeProperties(Properties source, Properties update)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.runtime.model.Descriptor

doesRemove, merge

Field Details

name

public String name

zkServers

@Deprecated
public String zkServers

Deprecated.

topicPrefix

public String topicPrefix

randomPrefix

public Boolean randomPrefix

copy

public String copy

producerProperties

public KafkaConfigDescriptor.ProducerProperties producerProperties

consumerProperties

public KafkaConfigDescriptor.ConsumerProperties consumerProperties

adminProperties

public KafkaConfigDescriptor.AdminProperties adminProperties

Constructor Details

KafkaConfigDescriptor

public KafkaConfigDescriptor()

Method Details

getId

public String getId()

Description copied from interface: Descriptor

The descriptor id, descriptors with same id are merged.

To forbid multiple descriptors use UNIQUE_DESCRIPTOR_ID.

To forbid merge use a unique value, non-overriden toString() for exemple.

Specified by:

getId in interface Descriptor

init

public void init(KafkaConfigDescriptor source)

mergeProperties

protected Properties mergeProperties(Properties source,
 Properties update)