chris created FLUME-3391:
----------------------------

             Summary: flume kafka sink 
无法配置ssl.endpoint.identification.algorithm =
                 Key: FLUME-3391
                 URL: https://issues.apache.org/jira/browse/FLUME-3391
             Project: Flume
          Issue Type: Bug
          Components: Sinks+Sources
    Affects Versions: 1.9.0
            Reporter: chris


在使用kafka sink时候需要将属性设置为空字符串

ssl.endpoint.identification.alogorithm =

但是由于flume在加载配置时候判断参数为空时,直接将参数值为空字符串给去除了,导致无法设置该属性为空字符串

源码:flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java

源代码182行

if (value.isEmpty()) {
 addError(name, PROPERTY_VALUE_NULL, ERROR);
 return false;
}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to