public class KafkaConnectionPropertyNames extends java.lang.Object implements ConnectionPropertyNames
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
KAFKA_BROKERS |
static java.lang.String |
KAFKA_NUM_PARTITIONS_FOR_COUNT_EQUALS_ZERO |
static java.lang.String |
KAFKA_ZK_ADDRESS |
PACKAGE_NAME
Constructor and Description |
---|
KafkaConnectionPropertyNames() |
Modifier and Type | Method and Description |
---|---|
java.lang.String[] |
get()
Get the message bus specific property names
|
public static final java.lang.String KAFKA_BROKERS
public static final java.lang.String KAFKA_ZK_ADDRESS
public static final java.lang.String KAFKA_NUM_PARTITIONS_FOR_COUNT_EQUALS_ZERO
public java.lang.String[] get()
ConnectionPropertyNames
get
in interface ConnectionPropertyNames