org.nuxeo.lib.stream.tools

Class KafkaConfigParser

java.lang.Object

org.nuxeo.lib.stream.tools.KafkaConfigParser

public class KafkaConfigParser
extends Object

Parse an xml file describing Kafka configurations, the format is the one used by KafkaConfigDescriptor. We can not use the Nuxeo descriptor directly because we are in a library without Nuxeo dependency.

Since:

9.10

Field Summary

Fields

Modifier and Type	Field and Description
protected Properties	consumerProperties
protected static String	DEFAULT_BOOTSTRAP_SERVERS
protected String	prefix
protected Properties	producerProperties

Constructor Summary

Constructors

Constructor and Description
KafkaConfigParser(Path path, String configName)

Method Summary

Modifier and Type	Method and Description
protected Properties	decodeProperties(Node node)
Properties	getConsumerProperties()
String	getPrefix()
Properties	getProducerProperties()
protected void	parseConfig(Node node)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BOOTSTRAP_SERVERS

protected static final String DEFAULT_BOOTSTRAP_SERVERS

See Also:

Constant Field Values

producerProperties

protected Properties producerProperties

consumerProperties

protected Properties consumerProperties

prefix

protected String prefix

Constructor Detail

KafkaConfigParser

public KafkaConfigParser(Path path,
                         String configName)

Method Detail

parseConfig

protected void parseConfig(Node node)

decodeProperties

protected Properties decodeProperties(Node node)

getProducerProperties

public Properties getProducerProperties()

getConsumerProperties

public Properties getConsumerProperties()

getPrefix

public String getPrefix()