com.opendxl.databus.producer.internal

Class ProducerDefaultConfiguration

java.lang.Object

com.opendxl.databus.producer.internal.ProducerDefaultConfiguration

public final class ProducerDefaultConfiguration
extends java.lang.Object

This class contains a set of config properties values that will be added to DatabusProducer unless they are provided by the SDK user

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MAX_BLOCK_MS_CONFIG_DEFAULT_VALUE The max time in ms that controls how long the producer will block when calling send() method
static java.lang.String	MAX_BLOCK_MS_CONFIG_KEY The key name of the max block ms configuration parameter

Method Summary

Modifier and Type	Method and Description
static java.lang.String	get(java.lang.String key)
static java.util.Properties	getAll()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BLOCK_MS_CONFIG_DEFAULT_VALUE

public static final java.lang.String MAX_BLOCK_MS_CONFIG_DEFAULT_VALUE

The max time in ms that controls how long the producer will block when calling send() method

See Also:

Constant Field Values

MAX_BLOCK_MS_CONFIG_KEY

public static final java.lang.String MAX_BLOCK_MS_CONFIG_KEY

The key name of the max block ms configuration parameter

See Also:

Constant Field Values

Method Detail

getAll

public static java.util.Properties getAll()

Returns:

all configuration properties

get

public static java.lang.String get(java.lang.String key)

Parameters:

key - the property key to look for

Returns:

the String value mapped to the key. Returns null if it is not mapped. If a string is returned, DatabusProducer will add it unless it being provided by the SDK user. If null is returned,DatabusProducer will take Kafka default configuration for the key.