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
All Methods Instance Methods Concrete Methods 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 Detail
-
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
-
-
Method Detail
-
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 interfaceDescriptor
-
init
public void init(KafkaConfigDescriptor source)
-
mergeProperties
protected Properties mergeProperties(Properties source, Properties update)
-
-