GitHub user sv3nd opened a pull request:
https://github.com/apache/kafka/pull/3982
TRIVIAL: fix connect Flatten error message
In case of an error while flattening a record with schema, the Flatten
transform was reporting an error about a record without schema, as follows:
```
org.apache.kafka.connect.errors.DataException: Flatten transformation does
not support ARRAY for record without schemas (for field ...)
```
The expected behaviour would be an error message specifying "with schemas".
This looks like a simple copy/paste typo from the schemaless equivalent
methods, in the same file
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sv3nd/kafka
svend/fix-flatten-error-log-message
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3982.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3982
----
commit 8c46e1ec4199878f7e0c1401a768da8501350da8
Author: Svend Vanderveken <svend.vanderve...@gmail.com>
Date: 2017-09-28T11:49:46Z
fix connect Flatten error message
In case of an error while flattening a record with schema, the Flatten
transform was reporting an error about a record without schema
----
---
