DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
- org.apache.kafka.server.config.ServerLogConfigs
- org.apache.kafka.server.config.ServerConfigs
Proposed Changes
log.dirs & log.dir
...
| Code Block | ||
|---|---|---|
| ||
public static final String LOG_DIRS_CONFIG = LOG_PREFIX + "dirs";
public static final String LOG_DIRS_DEFAULT = "/tmp/kafka-logs";
public static final String LOG_DIRS_DOC = "A comma-separated list of the directories where the log data is stored.";// define class
public class LogConfig extends AbstractConfig { // skip
.define(ServerLogConfigs.LOG_DIRS_CONFIG, STRING, ServerLogConfigs.LOG_DIRS_DEFAULT, ConfigDef.ValidList.anyNonDuplicateValues(false, false), HIGH, ServerLogConfigs.LOG_DIRS_DOC) // skip
} |
node.id & broker.id
The broker.id configuration is used in ZooKeeper mode. In KRaft mode, however, it is awkward to set a broker.id for a controller node. This makes the configuration outdated. Instead, node.id provides a more meaningful and semantic option in KRaft mode.
| Code Block | ||
|---|---|---|
| ||
@Deprecated
public static final String BROKER_ID_CONFIG = "broker.id";
@Deprecated
public static final int BROKER_ID_DEFAULT = -1;
@Deprecated
public static final String BROKER_ID_DOC = "The broker id for this server. This configuration will be remove in Kafka 5.0. " +
"Please use <code>node.id</code> instead."; |
Compatibility, Deprecation, and Migration Plan
...