现在有个项目是java整合datax从kafka同步数据到kafka，其中两个kafka的数据格式不相同，所以要用java代码写一个自定义的transformer插件txt2jsontransformer，先将kafkarewder的数据转换成json格式再写入kafkawriter中，其中txt2Jsontransformer插件的属性有column：里面放的都是要转换的字段名，如何用java代码写一个Txt2JsonTransformer类要求继承ComplexTransformer类，重写evaluate方法，实现以上的功能

这是一个比较具体的项目需求，需要涉及到Java编程、DataX、Kafka等技术。下面是一个可能的实现方案：

1. 创建一个Java类Txt2JsonTransformer，继承自ComplexTransformer类。

public class Txt2JsonTransformer extends ComplexTransformer {
    private List<String> columns;
    
    @Override
    public void init() {
        // 读取配置文件中的column属性，解析成List<String>
        columns = Arrays.asList(getStringParameter("column").split(","));
    }
    
    @Override
    public Record evaluate(Record record, Object... paras) {
        // 遍历需要转换的字段
        for (String column : columns) {
            // 获取该字段的值
            String value = record.getColumn(column).asString();
            // 将该字段的值转换成JSON格式
            String json = convertToJson(value);
            // 将JSON格式的值写入到该字段
            record.setColumn(column, json);
        }
        return record;
    }
    
    private String convertToJson(String value) {
        // 实现将文本格式的数据转换成JSON格式的逻辑
        // ...
        return json;
    }
}

2. 在DataX的配置文件中，指定使用Txt2JsonTransformer作为transformer插件，并设置column属性。

{
    "job": {
        "content": [
            {
                "reader": {
                    "name": "kafkareader"
                },
                "transformer": [
                    {
                        "name": "txt2jsontransformer",
                        "parameter": {
                            "column": "field1,field2"
                        }
                    }
                ],
                "writer": {
                    "name": "kafkawriter"
                }
            }
        ]
    }
}

3. 在DataX的启动命令中，加入Txt2JsonTransformer类的jar包路径。

datax.py -job job.json -mode standalone -pluginRootPath /path/to/txt2jsontransformer.jar

这样就完成了从Kafka读取数据，通过Txt2JsonTransformer转换成JSON格式，再写入到另一个Kafka的整个流程。其中Txt2JsonTransformer的实现逻辑需要根据具体的需求进行编写，这里只是给出了一个可能的思路。