我正在使用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