大数据
flinkbug 标签描述

 问题1:没有重写方法toString 最终的合流无法显示,是因为orderWide没有重写方法toString 并且此合流后的数据还没有sink,仅仅是消费kafka,因此重写方法后,默认之前的kafkaoffset已经提交,对于同一消费组不会再重复消费,所以需要修改消费组再重新运行。 @Override publicStringtoString(){ returnJSON.toJSONString(this,SerializerFeature.WriteMapNullValue); } 问题2:如何将json中null字段打印输出,可以不区分字段类型,所有null都输出为"...

  UqrkOCyfkQZc   2023年11月02日   63   0   0 flinkbugflinkbugidekafkaHTMLkafkaideHTML