[pulsar] branch master updated: Miss put the SSL_TRUSTSTORE_LOCATION_CONFIG to SSL_TRUSTSTORE_PASSWORD in kafka sink (#12545)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new abf7114  Miss put the SSL_TRUSTSTORE_LOCATION_CONFIG to 
SSL_TRUSTSTORE_PASSWORD in kafka sink (#12545)
abf7114 is described below

commit abf7114e920bcff800552814546a7a867527fa41
Author: ZhangJian He <shoot...@gmail.com>
AuthorDate: Mon Nov 1 20:55:10 2021 +0800

    Miss put the SSL_TRUSTSTORE_LOCATION_CONFIG to SSL_TRUSTSTORE_PASSWORD in 
kafka sink (#12545)
---
 .../src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
 
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
index 7bfbc21..6efe87a 100644
--- 
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
+++ 
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
@@ -116,7 +116,7 @@ public abstract class KafkaAbstractSink<K, V> implements 
Sink<byte[]> {
             props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, 
kafkaSinkConfig.getSslTruststoreLocation());
         }
         if 
(StringUtils.isNotEmpty(kafkaSinkConfig.getSslTruststorePassword())) {
-            props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, 
kafkaSinkConfig.getSslTruststorePassword());
+            props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, 
kafkaSinkConfig.getSslTruststorePassword());
         }
         props.put(ProducerConfig.ACKS_CONFIG, kafkaSinkConfig.getAcks());
         props.put(ProducerConfig.BATCH_SIZE_CONFIG, 
String.valueOf(kafkaSinkConfig.getBatchSize()));