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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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)
-
filterDisplayedProperties
protected String filterDisplayedProperties(Properties properties)
-
-