All Questions
Tagged with protobuf-python apache-flink
2 questions
0
votes
0
answers
46
views
Issue Decoding Protobuf Messages from Kafka in PyFlink Due to String Conversion
We are trying to consume Protobuf-encoded messages from a Kafka topic using PyFlink. However, we are encountering message parsing errors when attempting to decode the messages later in our pipeline.
...
0
votes
1
answer
595
views
Apache Flink Stateful Function - Serialization problem?
I'm trying to build a project using an Apache Flink Stateful Function in Python, but I can't seem to get it to work. What I've narrowed the issue down to is that it seems when I send the request to ...
- 1,346