小编Вик*_*тор的帖子

我想在kafka主题数据集json中写入

我有 Dataset 对象，我将其转换为 Dataset 字符串，其中该字符串包含 json 对象。这是我在主题中记录发送的。之前一切都记录得很好，但是添加一个字段后，就开始出现异常。我想尝试连接 KryoSerializer 但无法建模：

public class ObjectCH implements Serializable {
    private static final long serialVersionUID = 8065906683154831478L;

    private Integer adtp;
    private String advid;
    private String app;
    private String date;
    private String deviceType;
    private Integer dnt;
    private Long duration;
    private Boolean geoIsRu;
    private Long inViewTime;
    private Boolean isError;
    private String ip;
    private Integer onScreenRate;
    private String os;
    private String osver;
    private Long sets;
    private String tmsec;
    private Integer tz;
    private String uid;
    private String ver; …