KafkaPublishRecord_2_0 JAAS配置sasl.jaas.config

Question

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

在哪里可以更新处理器中的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

我已经更新了其他属性。

Answer 1

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