Package org.nuxeo.lib.stream.log.kafka

Class KafkaLogConfig

java.lang.Object

org.nuxeo.lib.stream.log.AbstractLogConfig

org.nuxeo.lib.stream.log.kafka.KafkaLogConfig

All Implemented Interfaces:

LogConfig

public class KafkaLogConfig
extends AbstractLogConfig

Since:

11.1

Field Summary

Fields

Modifier and Type	Field	Description
protected Properties	adminProperties
protected Properties	consumerProperties
static String	DEFAULT_REPLICATION_FACTOR_PROP
protected short	defaultReplicationFactor
static String	DISABLE_SUBSCRIBE_PROP
protected Boolean	disableSubscribe
protected String	name
protected Properties	producerProperties
protected NameResolver	resolver

Fields inherited from class org.nuxeo.lib.stream.log.AbstractLogConfig

defaultConfig, patterns

Constructor Summary

Constructors

Constructor	Description
KafkaLogConfig(String name, boolean defaultConfig, List<String> patterns, String prefix, Properties adminProperties, Properties producerProperties, Properties consumerProperties)

Method Summary

Modifier and Type	Method	Description
protected Properties	createAdminProperties(Properties producerProperties)
protected String	filterDisplayedProperties(Properties properties)
Properties	getAdminProperties()
Properties	getConsumerProperties()
Boolean	getDisableSubscribe()
Properties	getProducerProperties()
short	getReplicatorFactor()
NameResolver	getResolver()
protected Properties	normalizeAdminProperties(Properties adminProperties)
protected Properties	normalizeConsumerProperties(Properties consumerProperties)
protected Properties	normalizeProducerProperties(Properties producerProperties)
String	toString()

Methods inherited from class org.nuxeo.lib.stream.log.AbstractLogConfig

isDefault, match, match

Methods inherited from class java.lang.Object

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

Field Detail

DISABLE_SUBSCRIBE_PROP

public static final String DISABLE_SUBSCRIBE_PROP

See Also:

Constant Field Values

DEFAULT_REPLICATION_FACTOR_PROP

public static final String DEFAULT_REPLICATION_FACTOR_PROP

See Also:

Constant Field Values

adminProperties

protected final Properties adminProperties

producerProperties

protected final Properties producerProperties

consumerProperties

protected final Properties consumerProperties

defaultReplicationFactor

protected final short defaultReplicationFactor

disableSubscribe

protected final Boolean disableSubscribe

resolver

protected final NameResolver resolver

name

protected final String name

Constructor Detail

KafkaLogConfig

public KafkaLogConfig(String name,
                      boolean defaultConfig,
                      List<String> patterns,
                      String prefix,
                      Properties adminProperties,
                      Properties producerProperties,
                      Properties consumerProperties)

Method Detail

getReplicatorFactor

public short getReplicatorFactor()

getDisableSubscribe

public Boolean getDisableSubscribe()

getResolver

public NameResolver getResolver()

getAdminProperties

public Properties getAdminProperties()

getProducerProperties

public Properties getProducerProperties()

getConsumerProperties

public Properties getConsumerProperties()

normalizeAdminProperties

protected Properties normalizeAdminProperties(Properties adminProperties)

normalizeProducerProperties

protected Properties normalizeProducerProperties(Properties producerProperties)

normalizeConsumerProperties

protected Properties normalizeConsumerProperties(Properties consumerProperties)

createAdminProperties

protected Properties createAdminProperties(Properties producerProperties)

toString

public String toString()

Overrides:

toString in class Object

filterDisplayedProperties

protected String filterDisplayedProperties(Properties properties)