kafka-jslt-tansform

基于jstl的kafka connect的transform。使用jstl处理kafka json数据 JSLT是对JSON进行查询和转换语言，这个项目将其应用与kafka connect的transform。

JSLT GitHub: https://github.com/schibsted/jslt

elgca.kafka.connect.JSLTTransformation

同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