Hi Dan,
I'm assuming that you have different Kafka topics, and each topic contains
messages of a single protobuf type.
In that case, you have to specify the mapping between a topic name to it's
Protobuf message type.
To do that, assume that you have a Kafka topic *A* that contains protobuf
Hi,
I’m trying to work through an example with Flink Stateful Functions in Python.
I have a series of custom protobuf messages that I’ve defined but I’m
struggling with how they should be provided to the runtime so the messages in
Kafka can be deserialized. I see,
type:
