unsubscribe

Unsubscribe

Calling 3rd party JARs from Pyflink

Hello, I want to read data from Kafka topics which have Confluent-encoded Protobuf messages (not plain Protobuf, Confluent adds a "magic byte" and schema ID) with Python Datastream API. I have found that Confluent has a Java class[1] which implements org.apache.kafka.common.serialization.Deseriali