From e773d14d5f888044ee842d55775377877e30056c Mon Sep 17 00:00:00 2001 From: ricky-newsbreak Date: Wed, 20 Nov 2024 10:40:33 -0800 Subject: [PATCH] fis msp --- msp-monetization-msk.properties | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/msp-monetization-msk.properties b/msp-monetization-msk.properties index 5b31fcd11..97f8ae297 100644 --- a/msp-monetization-msk.properties +++ b/msp-monetization-msk.properties @@ -21,10 +21,22 @@ internal.value.converter=org.apache.kafka.connect.json.JsonConverter internal.key.converter.schemas.enable=false internal.value.converter.schemas.enable=false -# consumer auth config +# worker auth config security.protocol = SASL_SSL sasl.mechanism = AWS_MSK_IAM sasl.jaas.config = software.amazon.msk.auth.iam.IAMLoginModule required; sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler +# consumer auth config +consumer.security.protocol = SASL_SSL +consumer.sasl.mechanism = AWS_MSK_IAM +consumer.sasl.jaas.config = software.amazon.msk.auth.iam.IAMLoginModule required; +consumer.sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler + +# producer auth config +producer.security.protocol = SASL_SSL +producer.sasl.mechanism = AWS_MSK_IAM +producer.sasl.jaas.config = software.amazon.msk.auth.iam.IAMLoginModule required; +producer.sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler + plugin.path=/usr/share/java,/usr/share/confluent-hub-components \ No newline at end of file