Re: ClassNotFoundException when loading protobuf message class in Flink SQL

2022-10-05 Thread James McGuire via user
use > 'flink-sql-connector-kafka' instead of > 'flink-connector-kafka'. > > > James McGuire via user 于2022年10月5日周三 07:21写道: > >> Hi Flink Community, >> I am trying to prove out the new protobuf functionality added to 1.16 >> ([1]). I have bui

ClassNotFoundException when loading protobuf message class in Flink SQL

2022-10-04 Thread James McGuire via user
Hi Flink Community, I am trying to prove out the new protobuf functionality added to 1.16 ([1]). I have built master locally and have attempted following the Protobuf Format doc ([2]) to create a table with the kafka connector using the protobuf format. I compiled the sample .proto file using pro