diff --git a/CHANGELOG.md b/CHANGELOG.md index 308f41e..7dcbc85 100644 --- 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 index 85930f6..c33911a 100644 --- 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 index 58fca5c..cd5a87b 100644 --- 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 errorResponse = OBJECT_READER.readValue(errorString);