public class KafkaConfigs extends Object
| Modifier and Type | Field and Description |
|---|---|
static String |
ACKS |
static int |
AGENT_MASTER_CMD_PARTITION |
static int |
AGENT_MASTER_SECRET_PARTITION |
static String |
AUTO_OFFSET_RESET |
static String |
BOOTSTRAP_SERVERS |
static String |
ENABLE_AUTO_COMMIT |
static String |
GROUP_ID |
static String |
KEY_DESERIALIZER |
static String |
KEY_SERIALIZER |
static int |
MASTER_AGENT_CMD_PARTITION |
static int |
MASTER_AGENT_SECRET_PARTITION |
static String |
VALUE_DESERIALIZER |
static String |
VALUE_SERIALIZER |
| Constructor and Description |
|---|
KafkaConfigs() |
| Modifier and Type | Method and Description |
|---|---|
static String |
getAgentMasterCommandKey(String agentName,
URL masterURL) |
static String |
getAgentMasterSecretKey(String agentName,
URL masterURL) |
static String |
getConnectionTopic(String agentName,
URL masterURL) |
static String |
getConsumerGroupID(String agentName,
URL masterURL) |
static String |
getMasterAgentCommandKey(String agentName,
URL masterURL) |
static String |
getMasterAgentSecretKey(String agentName,
URL masterURL) |
public static final String BOOTSTRAP_SERVERS
public static final String KEY_SERIALIZER
public static final String VALUE_SERIALIZER
public static final String ACKS
public static final String GROUP_ID
public static final String ENABLE_AUTO_COMMIT
public static final String KEY_DESERIALIZER
public static final String VALUE_DESERIALIZER
public static final String AUTO_OFFSET_RESET
public static final int MASTER_AGENT_CMD_PARTITION
public static final int AGENT_MASTER_CMD_PARTITION
public static final int MASTER_AGENT_SECRET_PARTITION
public static final int AGENT_MASTER_SECRET_PARTITION
public static String getMasterAgentCommandKey(String agentName, URL masterURL)
public static String getAgentMasterCommandKey(String agentName, URL masterURL)
public static String getMasterAgentSecretKey(String agentName, URL masterURL)
Copyright © 2004–2018. All rights reserved.