fix bug with explicitly-specified Java codecs

Fixes #10520
elastic · Mar 8, 2019 · 0910353 · 0910353
1 parent 7db4fab
commit 0910353
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/logstash-core/src/main/java/org/logstash/plugins/ConfigurationImpl.java b/logstash-core/src/main/java/org/logstash/plugins/ConfigurationImpl.java
@@ -39,6 +39,9 @@ public <T> T get(final PluginConfigSpec<T> configSpec) {
             Object o = rawSettings.get(configSpec.name());
             if (configSpec.type().isAssignableFrom(o.getClass())) {
                 return (T) o;
+            } else if (configSpec.type() == Codec.class && o instanceof String && pluginFactory != null) {
+                Codec codec = pluginFactory.buildDefaultCodec((String)o);
+                return configSpec.type().cast(codec);
             } else {
                 throw new IllegalStateException(
                         String.format("Setting value for '%s' of type '%s' incompatible with defined type of '%s'",