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 static String	DEFAULT_BOOTSTRAP_SERVERS
protected static String	DEFAULT_ZK_SERVERS
protected String	zkServers

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()
String	getZkServers()
protected void	parseConfig(Node node)
void	setZkServers(String zkServers)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ZK_SERVERS

protected static final String DEFAULT_ZK_SERVERS

See Also:

Constant Field Values

DEFAULT_BOOTSTRAP_SERVERS

protected static final String DEFAULT_BOOTSTRAP_SERVERS

See Also:

Constant Field Values

zkServers

protected String zkServers

Constructor Detail

KafkaConfigParser

public KafkaConfigParser(Path path,
                         String configName)

Method Detail

parseConfig

protected void parseConfig(Node node)

decodeProperties

protected Properties decodeProperties(Node node)

getZkServers

public String getZkServers()

getProducerProperties

public Properties getProducerProperties()

getConsumerProperties

public Properties getConsumerProperties()

getPrefix

public String getPrefix()

setZkServers

public void setZkServers(String zkServers)