-
Notifications
You must be signed in to change notification settings - Fork 8
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support json arrays #6
base: master
Are you sure you want to change the base?
Conversation
0f136fb
to
de7031d
Compare
de7031d
to
c9d4332
Compare
Just tested to confirm this works. The _id don't conflict because each batch is assigned an _id, then a suffix is used to denote the position in the list of the batch write. |
@@ -70,10 +71,7 @@ public Map<String, Object> parseValue(SinkRecord record) { | |||
log.warn(message, cause); | |||
throw new RuntimeException(message, e); | |||
} | |||
|
|||
int size = maps.size(); | |||
checkArgument(size == 1, "Only 1 object allowed in list type messages. Found %s", size); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just curious, why do we even have this constraint before?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
An additional backend change is required if there is more than one document in the payload.
I will hold off on merging until backend changes are ready. |
Adds support for parsing JSON arrays with multiple values