diff --git a/data-prepper-api/src/test/java/org/opensearch/dataprepper/model/configuration/SinkForwardConfigTest.java b/data-prepper-api/src/test/java/org/opensearch/dataprepper/model/configuration/SinkForwardConfigTest.java index 1732468798..e6e778172c 100644 --- a/data-prepper-api/src/test/java/org/opensearch/dataprepper/model/configuration/SinkForwardConfigTest.java +++ b/data-prepper-api/src/test/java/org/opensearch/dataprepper/model/configuration/SinkForwardConfigTest.java @@ -9,6 +9,7 @@ package org.opensearch.dataprepper.model.configuration; +import com.fasterxml.jackson.databind.ObjectMapper; import org.opensearch.dataprepper.model.plugin.InvalidPluginConfigurationException; import org.junit.jupiter.api.Test; @@ -54,5 +55,14 @@ void pipelines_list_with_two_or_more_pipelines_throws_exception() { void empty_pipelines_list_throws_exception() { assertThrows(InvalidPluginConfigurationException.class, ()->new SinkForwardConfig(List.of(), Map.of(), Map.of())); } + + @Test + void jackson_deserialization_succeeds() throws Exception { + String json = "{\"pipelines\":[\"pipeline1\"],\"with_data\":{\"key\":\"value\"},\"with_metadata\":{\"meta\":\"data\"}}"; + ObjectMapper mapper = new ObjectMapper(); + SinkForwardConfig config = mapper.readValue(json, SinkForwardConfig.class); + assertThat(config.getPipelineNames().size(), equalTo(1)); + assertThat(config.getPipelineNames().get(0), equalTo("pipeline1")); + } }