我正在使用kafka_2.10-0.10.0.1和scala_2.10.3。 我想用scala编写自定义串行器和解串器。 我与这些串行(从CustomType)及解串器试图(获得CustomType): class CustomTypeSerializer extends Serializer[CustomType] {
private val gson: Gson = new Gson
我有这个类: public class DbReturned<T> {
public boolean State;
public int UserID;
public String Error;
public T row;
public List<T> Data;
public boolean Hr;
public boolea