在这里,DataStream将键值对作为对象返回,我需要直接使用键值,而不是对象,因为我需要根据键对值进行分组。record1").print(); 当我给stream.keyby(“record1”).print()时,它显示 Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: This type (GenericType<org.apache.flink.shaded.
我已经创建了自己的反序列化模式(使用Jackson),当使用的消息实际上是一个表示case类的JSON时,它可以正常工作。在使用消息之前,我可以验证它吗?如果我可以在兔子中设置一个死信交换,我应该在哪里(如果可能的话)代表Apache作为消费者进行负面的确认?有一种更好的方法来处理这个问题,并让作业运行使用下一个格式良好的消息?:331)
at org.apache.flink.streaming.api.operators.StreamSou