第 5 章为 Apache Kafka 配置流

使用 Kafka 和 ZooKeeper 属性文件为 Apache Kafka 配置流。

属性文件是 Java 格式，每个属性位于一个独立的行中，使用一些格式：

<option> = <value>

<option> = <value>

Copy to Clipboard

Toggle word wrap

以 # 或 ! 开头的行将被视为注释，并将由 Apache Kafka 组件的 Streams 忽略。

This is a comment

# This is a comment

Copy to Clipboard

Toggle word wrap

可以使用 \ 在换行 / carriage 返回前直接将值分成多行。

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
    username="bob" \
    password="bobs-password";

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
    username="bob" \
    password="bobs-password";

Copy to Clipboard

Toggle word wrap

在属性文件中保存更改后，您需要重启 Kafka 代理或 ZooKeeper。在多节点环境中，您需要在集群中的每个节点上重复该过程。

5.1. 使用标准 Kafka 配置属性
复制链接

使用标准 Kafka 配置属性来配置 Kafka 组件。

属性提供控制和调整以下 Kafka 组件配置的选项：

代理和客户端参数包括配置授权、身份验证和加密的选项。

如需有关 Kafka 配置属性以及如何使用属性调整部署的更多信息，请参阅以下指南：

返回顶部