KafkaPublishRecord_2_0 JAAS 配置 sasl.jaas.config

KafkaPublishRecord_2_0 JAAS config sasl.jaas.config

我正在尝试使用 SASL_SSL 属性更新我的 PublishKafkaRecord_2_0 处理器。

我在哪里可以更新处理器中的 sasl.jaas.config 属性?

  1. sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KAFKA_USERNAME}" password="${KAFKA_PASSWORD}";
  2. sasl.mechanism=PLAIN

我已经更新了其他属性。

您可以将用户定义的 属性 添加到处理器(属性右上角的 + 图标)。任何用户定义的属性都将传递给 Kafka 配置。