| Option | KAFKA_COMMON_ | |
| Description |
Allows you to pass configuration parameters to all Kafka clients.
Replaces EXTRA_KAFKA_CONFIGS_FILE. If a parameter
set here is also set in a client-specific prefix, then this has
lower precedence than the others. For example, if you set both
KAFKA_COMMON_BLAH and
KAFKA_GLOBAL_CONSUMER_BLAH, then
for the global consumer, the latter "wins".
| |
| Introduced Version | 1.173.0 | |
Use the KAFKA_COMMON prefix to
pass a configuration to all clients. For example, this enables
LogScale to connect to a Kafka cluster using SSL and
SASL.
Kafka configuration options, such as
request.timeout.ms can be passed
with the prefix using a simple rewrite:
Write the option name in uppercase (example:
REQUEST.TIMEOUT.MS).Replace
.with_(example:REQUEST_TIMEOUT_MS)Apply the prefix for the target client (example:
KAFKA_COMMON_REQUEST_TIMEOUT_MS)Pass this as an environment variable to LogScale on boot (example:
KAFKA_COMMON_REQUEST_TIMEOUT_MS=30000)
For a list of all possible Kafka configuration options, see Configuration.
If you want to pass a client-specific configuration, see the
KAFKA_ADMIN,
KAFKA_CHATTER_CONSUMER,
KAFKA_CHATTER_PRODUCER,
KAFKA_GLOBAL_CONSUMER,
KAFKA_GLOBAL_PRODUCER,
KAFKA_INGEST_QUEUE_CONSUMER,
or KAFKA_INGEST_QUEUE_PRODUCER
prefixes instead. Settings configured using the client-specific
prefixes above have precedence if the setting is present with
both KAFKA_COMMON and one of
the other prefixes. For example, you could set
KAFKA_COMMON_BLAH=5 and
KAFKA_GLOBAL_CONSUMER_BLAH=10.
Then BLAH would be set to 10 for
the global consumer, while all other clients have it set to 5.