Comments (5)
Hi, @lbh375441316
Did you manage to solve this issue?
Thanks,
from kafka-connect-elasticsearch.
Hard to say what the issue is since this this is coming from the underlying library and indicates that ES is returning an invalid JSON response. Are there any other messages in the log before the exception? Without more info about what is being returned in the request it'll be hard to get to the root cause.
from kafka-connect-elasticsearch.
I had the same problem. It is the problem of jest client version and es version in my project. Jest client used in connector is 2.0.0, it doesn't support es 5.x, ex: create index in ex5.x use put not post. So I can't get more info about what is being returned in the request, because jest directly parse the reponse and don't catch not checked exception:
io.searchbox.action.AbstractAction#parseResponseBody(line 98)
protected JsonObject parseResponseBody(String responseBody) {
if (responseBody == null || responseBody.trim().isEmpty()) {
return new JsonObject();
}
JsonElement parsed = new JsonParser().parse(responseBody);
if (parsed.isJsonObject()) {
return parsed.getAsJsonObject();
} else {
throw new JsonSyntaxException("Response did not contain a JSON Object");
}
}
if parse like this,there will be more logs:
JsonElement parsed;
try {
parsed = new JsonParser().parse(responseBody);
}catch (JsonSyntaxException e) {
throw new RuntimeException("Can't parse response[" + responseBody + "]", e);
}
from kafka-connect-elasticsearch.
I had similar issue a couple of month ago when moving to new ES version. Try to use
jestVersion = "2.4.0"
"io.searchbox" % "jest" % jestVersion
from kafka-connect-elasticsearch.
closing because connector runs on newer jest version now
from kafka-connect-elasticsearch.
Related Issues (20)
- How to Convert JSON String field to ES Object?
- Capture Kafka key without using it as ID HOT 2
- Suggestion for INSERT operation "Ignoring EXTERNAL version conflict for operation INDEX on document"
- Used Elastic Java REST client is deprecated in 7.15.0 HOT 1
- Error with `"behavior.on.null.values": "delete"`
- Consumer paused indefinitely when using `AsyncOffsetTracker` with lot of null values
- Cannot use data stream with time_series mode HOT 2
- Error: Cannot infer mapping without schema HOT 1
- Connector fails with payloads >20 MB HOT 1
- Can't create a connector even if its loaded in Strimzi
- Support requests per second configuration options
- Log when there are too many requests errors
- [BUG] `TOO_MANY_REQUESTS` error craches the tasks with a unrecoverable exceptions without retries
- Ignore 'document_parsing_exception' HOT 1
- Inconsistent Logging for Tombstone Messages in Elastic Sink Connector
- abnormal data loss question
- Data Stream naming is far too restrictive HOT 1
- Creating index based on Timestamp doesn't work
- Limit retry backoff (and unlimited retries) HOT 4
- add support for index templates other than logs and metrics as types when using data streams
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from kafka-connect-elasticsearch.