KafkaConfigParser (Nuxeo 2021.70.4 API Documentation)

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 String`	`DEFAULT_BOOTSTRAP_SERVERS`
`protected String`	`prefix`
`protected Properties`	`producerProperties`

Constructor Summary

Constructors
Constructor Description

KafkaConfigParser(Path path, String configName)

Method Summary

All Methods Instance Methods Concrete Methods
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 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()
```