Thanks for the tip, I will use the flink-sql-connector-kafka jar instead.
I was able to get it to work by moving the SimpleTest.jar inside the lib
folder. I am not sure why this worked but passing in the jar with the
--jar flag did not work.
Thanks,
James
On Tue, Oct 4, 2022 at 7:32 PM Benchao
Hi James,
Your steps seem right. Could you check your jar file
'~/repos/simple_protobuf/SimpleTest/SimpleTest.jar'
that it does contain 'com.example.SimpleTest.class'?
Besides that, to use Kafka connector in sql-client, you should use
'flink-sql-connector-kafka' instead of
'flink-connector-kafka'
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
