Hi Everyone, Does flink Kafka connector supports c...
# random
r
Hi Everyone, Does flink Kafka connector supports confluent schema registry URL for deserialising Kafka messages serialised with Protobuf? I see the option for avro but not for protobuf. It is turning out to be hard to supply java code bindings jar file and class name for reading from Kafka protobuf topics.
m
Not yet, but I do expect that it will be there in the next weeks/months
👀 3
👍 3
a
Ah.. ‘avro-confluent.url’
Can Flink create the schema registry entry?
r
@Martijn Visser do you know how soon would that be? We are evaluating flink and spark to reach from Kafka and we were inclined towards flink, but this comes out to be an issue as we use protobuf heavily in our organisation for Kafka topics.
m
@rahul gulati Not in this Flink release, but the one after (1.19)
r
Okay thanks, so this means somewhere around in Q4, is that correct?
m
Probably a bit earlier but yes
r
Thanks for your replies :) @Martijn Visser