From 2137ae3dbc201592a46b1932d84e4cb1ce2810cb Mon Sep 17 00:00:00 2001
From: lenovo <sunfangbin@gmail.com>
Date: Wed, 24 Apr 2019 16:58:10 +0800
Subject: [PATCH] Add sensitive annotations for Solr/RabbitMQ connector.

---
 .../org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java   | 2 ++
 .../src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java
index 97174d08cf2fd..a9386d41c1183 100644
--- a/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java
+++ b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java
@@ -71,12 +71,14 @@ public class RabbitMQAbstractConfig implements Serializable {
     @FieldDoc(
         required = false,
         defaultValue = "guest",
+        sensitive = true,
         help = "The username used to authenticate to RabbitMQ")
     private String username = "guest";
 
     @FieldDoc(
         required = false,
         defaultValue = "guest",
+        sensitive = true,
         help = "The password used to authenticate to RabbitMQ")
     private String password = "guest";
 
diff --git a/pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java b/pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java
index 7176c58a0e1f4..ccf25f5c728bb 100644
--- a/pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java
+++ b/pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java
@@ -76,12 +76,14 @@ public class SolrSinkConfig implements Serializable {
     @FieldDoc(
         required = false,
         defaultValue = "",
+        sensitive = true,
         help = "The username to use for basic authentication")
     private String username;
 
     @FieldDoc(
         required = false,
         defaultValue = "",
+        sensitive = true,
         help = "The password to use for basic authentication")
     private String password;