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: statefun.kafka.io/routable-protobuf-ingress id: example/names in the example, but how can I change that to my.namespace.com/IngressMessage? Do I need to provide the protobuf compiled JAR in my Python app? Thanks Dan This e-mail, including attachments, may include confidential and/or proprietary information, and may be used only by the person or entity to which it is addressed. If the reader of this e-mail is not the intended recipient or his or her authorized agent, the reader is hereby notified that any dissemination, distribution or copying of this e-mail is prohibited. If you have received this e-mail in error, please notify the sender by replying to this message and delete this e-mail immediately.
