Re: Cannot catch exception throws by kafka consumer with JSONKeyValueDeserializationSchema

2019-07-09 Thread Zhechao Ma
> trying to capture exceptions in your code (preferably with posting your > relevant code directly > ). That will help us understand and locate the issue you encounter. > > Best, > Haibo > > At 2019-07-08 14:11:22, "Zhechao Ma" wrote: > > Hello, > > I&#

Cannot catch exception throws by kafka consumer with JSONKeyValueDeserializationSchema

2019-07-07 Thread Zhechao Ma
ot do that. Can anyone give out some tips? flink: 1.5 flink-kafka: 1.5 kafka-clients: 0.10.1.2_2.11 flink-json: -- Thanks Zhechao Ma