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 ---- ---