public class KafkaConf extends Object
| Modifier and Type | Field and Description |
|---|---|
static String |
HIGH_AUTO_COMMIT_INTERVAL |
static String |
HIGH_GROUP_ID |
static String |
HIGH_TOPIC |
static String |
HIGH_ZOOKEEPER_CONN |
static String |
HIGH_ZOOKEEPER_SESSION_TIMEOUT |
static String |
HIGH_ZOOKEEPER_SYNC_TIME |
static String |
JDQ_COMPRESSION |
static String |
JDQ_IS_CONTROL_SPEED |
static String |
JDQ_IS_SYNC |
static String |
JDQ_REPLICA_LEVEL |
static String |
JDQ_ZK_INFO |
static String |
PRODUCER_ACKS |
static String |
PRODUCER_BROKER_LIST |
static String |
PRODUCER_COMPRESSION_CODEC |
static String |
PRODUCER_KEY_SERIALIZER_CLASS |
static String |
PRODUCER_PARTITION_CLASS |
static String |
PRODUCER_REQUEST_TIMEOUT |
static String |
PRODUCER_TYPE |
static String |
PRODUCER_VALUE_SERIALIZER_CLASS |
static String |
SIMPLE_BROKER_LIST |
static String |
SIMPLE_END_OFFSETS |
static String |
SIMPLE_OFFSETS |
static String |
SIMPLE_PARTITIONS |
static String |
SIMPLE_TOPIC |
| Constructor and Description |
|---|
KafkaConf()
default props
|
| Modifier and Type | Method and Description |
|---|---|
String |
getProp(String key)
getOrigin properties value
|
Properties |
getProps()
getOrigin config properties
|
void |
setProp(String key,
String val)
set customer kafka config
|
String |
toString()
return config string show
|
public static final String PRODUCER_BROKER_LIST
public static final String PRODUCER_ACKS
public static final String PRODUCER_REQUEST_TIMEOUT
public static final String PRODUCER_TYPE
public static final String PRODUCER_VALUE_SERIALIZER_CLASS
public static final String PRODUCER_KEY_SERIALIZER_CLASS
public static final String PRODUCER_PARTITION_CLASS
public static final String PRODUCER_COMPRESSION_CODEC
public static final String HIGH_ZOOKEEPER_CONN
public static final String HIGH_GROUP_ID
public static final String HIGH_ZOOKEEPER_SESSION_TIMEOUT
public static final String HIGH_ZOOKEEPER_SYNC_TIME
public static final String HIGH_AUTO_COMMIT_INTERVAL
public static final String HIGH_TOPIC
public static final String SIMPLE_BROKER_LIST
public static final String SIMPLE_PARTITIONS
public static final String SIMPLE_OFFSETS
public static final String SIMPLE_END_OFFSETS
public static final String SIMPLE_TOPIC
public static final String JDQ_ZK_INFO
public static final String JDQ_IS_SYNC
public static final String JDQ_COMPRESSION
public static final String JDQ_REPLICA_LEVEL
public static final String JDQ_IS_CONTROL_SPEED
public void setProp(String key, String val)
key - val - public String toString()
public Properties getProps()
Copyright © 2016. All rights reserved.