基于jstl的kafka connect的transform。使用jstl处理kafka json数据 JSLT是对JSON进行查询和转换语言，这个项目将其应用与kafka connect的transform。
JSLT GitHub: https://github.com/schibsted/jslt
同ExtractField一样,JSLTTransformation可以分别对key和value使用
| class | type |
|---|---|
elgca.kafka.connect.JSLTTransformation$Key |
key |
elgca.kafka.connect.JSLTTransformation$Value |
value |
配置参数
| name | comment |
|---|---|
script.url |
通过url获取jslt脚本,不能与script.text同时使用 |
script.text |
jslt脚本,不能与script.url同时使用 |
charset |
编码，脚本编码和以byte[]形式接受数据的string编码 |
支持对Map<String,?>, Struct, String, byte[] 的输入处理, 输出类型改String为Map<String,?>
对于Source可以配合org.apache.kafka.connect.json.JsonConverter输出Json至kafka,
之前只能使用StringConverter