Package 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	Description
protected Properties	consumerProperties
protected static final String	DEFAULT_BOOTSTRAP_SERVERS
protected String	prefix
protected Properties	producerProperties

Constructor Summary

Constructors

Constructor	Description
KafkaConfigParser(Path path, String configName)

Method Summary

Modifier and Type	Method	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 Details

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 Details

KafkaConfigParser

public KafkaConfigParser(Path path,
 String configName)

Method Details

parseConfig

protected void parseConfig(Node node)

decodeProperties

protected Properties decodeProperties(Node node)

getProducerProperties

public Properties getProducerProperties()

getConsumerProperties

public Properties getConsumerProperties()

getPrefix

public String getPrefix()