flume-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "chris (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLUME-3391) flume kafka sink Unable to configure ssl.endpoint.identification.algorithm =
Date Thu, 20 May 2021 04:00:00 GMT

     [ https://issues.apache.org/jira/browse/FLUME-3391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

chris updated FLUME-3391:
-------------------------
    Description: 
When using Kafka sink, you need to set the property to an empty string

ssl.endpoint.identification.alogorithm =

However, when flume judges that the parameter is empty when loading configuration, it directly
removes the parameter value as an empty string, so it cannot set the attribute as an empty
string

source code: flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java

182 lines of source code

if (value.isEmpty())

{ addError(name, PROPERTY_VALUE_NULL, ERROR); return false; }

  was:
When using Kafka sink, you need to set the property to an empty string

ssl.endpoint.identification.alogorithm =

However, when flume judges that the parameter is empty when loading configuration, it directly
removes the parameter value as an empty string, so it cannot set the attribute as an empty
string

Source code: flume ng configuration / SRC / main / Java / org / Apache / flume / conf / flumeconfiguration.java

182 lines of source code

if (value.isEmpty())

{ addError(name, PROPERTY_VALUE_NULL, ERROR); return false; }


> flume kafka sink Unable to configure 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
>            Priority: Critical
>
> When using Kafka sink, you need to set the property to an empty string
> ssl.endpoint.identification.alogorithm =
> However, when flume judges that the parameter is empty when loading configuration, it
directly removes the parameter value as an empty string, so it cannot set the attribute as
an empty string
> source code: flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java
> 182 lines of source code
> 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: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org


Mime
View raw message