Merge pull request #127 from treasure-data/fix-response-header

Fix issue response header Marketo change from text/csv to text/csv;charset=UTF-8
treasure-data · Jun 13, 2024 · 51fbb8e · 51fbb8e
2 parents e3283d1 + 521dcd9
commit 51fbb8e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## 0.6.27
+- Fix issue response header Marketo change from text/csv to text/csv;charset=UTF-8
+
 ## 0.6.26
 - Catch up to Java 11
 

diff --git a/build.gradle b/build.gradle
@@ -13,7 +13,7 @@ repositories {
 
 group = "com.treasuredata.embulk.plugins"
 description = "Loads records from Marketo."
-version = "0.6.26"
+version = "0.6.27"
 
 sourceCompatibility = 1.8
 targetCompatibility = 1.8

diff --git a/src/main/java/org/embulk/input/marketo/rest/MarketoInputStreamResponseEntityReader.java b/src/main/java/org/embulk/input/marketo/rest/MarketoInputStreamResponseEntityReader.java
@@ -48,7 +48,7 @@ public Response getResponse() throws Exception
     @Override
     public InputStream readResponseContent() throws Exception
     {
-        if (!getResponse().getHeaders().getField(HttpHeader.CONTENT_TYPE).getValue().equals("text/csv")) {
+        if (!getResponse().getHeaders().getField(HttpHeader.CONTENT_TYPE).getValue().contains("text/csv")) {
             String errorString = readResponseContentInString();
 
             MarketoResponse<ObjectNode> errorResponse = OBJECT_READER.readValue(errorString);