public static final java.lang.String |
BROKER_ENDPOINTS_CONFIG |
"broker.endpoints" |
public static final java.lang.String |
BROKER_ENDPOINTS_DOC |
"A list of host/port pairs to use for contacting the Kafka brokers. This list should be in the form <code>host1:port1,host2:port2,...</code>." |
public static final java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_CONFIG |
"listener.security.protocol.map" |
public static final java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_DOC |
"A map between listener names and security protocols. The format is LISTENER_NAME1:SECURITY_PROTOCOL1,LISTENER_NAME2:SECURITY_PROTOCOL2,... Different security (SSL and SASL) settings can be configured for each listener by adding a normalised prefix (the listener name is lowercased) to the config name. For example, to set a different keystore for the INTERNAL listener, a config with name <code>listener.name.internal.ssl.keystore.location</code> would be set." |
public static final java.lang.String |
NUM_WORKER_POOL_THREADS_CONFIG |
"num.worker.pool.threads" |
public static final int |
NUM_WORKER_POOL_THREADS_DEFAULT |
10 |
public static final java.lang.String |
NUM_WORKER_POOL_THREADS_DOC |
"The number of worker pool threads." |
public static final java.lang.String |
TENANT_ENDPOINTS_CONFIG |
"tenant.endpoints" |
public static final java.lang.String |
TENANT_ENDPOINTS_DOC |
"A list of host/port pairs to set up for tenant endpoints. This list should be in the form <code>host1:port1,host2:port2,...</code>." |