Re: Error while fetching data from Apache Kafka

2021-09-14 Thread Dhiru
Thanks @caizhi , let me look this  On Monday, September 13, 2021, 10:24:03 PM EDT, Caizhi Weng wrote: Hi! This seems to be caused by some mismatching types in your source definition and your workflow. If possible could you describe the schema of your Kafka source and paste your datast

Re: Error while fetching data from Apache Kafka

2021-09-13 Thread Caizhi Weng
Hi! This seems to be caused by some mismatching types in your source definition and your workflow. If possible could you describe the schema of your Kafka source and paste your datastream / Table / SQL code here? Dhiru 于2021年9月14日周二 上午3:49写道: > *I am not sure when we try to receive data from Ap

Error while fetching data from Apache Kafka

2021-09-13 Thread Dhiru
I am not sure when we try to receive data from Apache Kafka I get this error , but works good for me when I try to run via Conflunece kafka java.lang.ClassCastException: class java.lang.String cannot be cast to class scala.Product (java.lang.String is in module java.base of loader 'bootstrap';