[FLUME-3391] flume kafka sink unable to configure ssl.endpoint.identification.algorithm =

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 1.9.0
• Component/s: Sinks+Sources
• Assignee: Unassigned
• Reporter: chris
• Created: 20/May/21 03:53
• Updated: 14/May/22 04:20

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; }