KafkaPublishRecord_2_0 JAAS 配置 sasl.jaas.config
KafkaPublishRecord_2_0 JAAS config sasl.jaas.config
我正在尝试使用 SASL_SSL 属性更新我的 PublishKafkaRecord_2_0 处理器。
我在哪里可以更新处理器中的 sasl.jaas.config 属性?
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KAFKA_USERNAME}" password="${KAFKA_PASSWORD}";
sasl.mechanism=PLAIN
我已经更新了其他属性。
您可以将用户定义的 属性 添加到处理器(属性右上角的 + 图标)。任何用户定义的属性都将传递给 Kafka 配置。
我正在尝试使用 SASL_SSL 属性更新我的 PublishKafkaRecord_2_0 处理器。
我在哪里可以更新处理器中的 sasl.jaas.config 属性?
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KAFKA_USERNAME}" password="${KAFKA_PASSWORD}";
sasl.mechanism=PLAIN
我已经更新了其他属性。
您可以将用户定义的 属性 添加到处理器(属性右上角的 + 图标)。任何用户定义的属性都将传递给 Kafka 配置。