Hi team, I want to consume message from kafka in protobuf format. Does dataStream API support that? Looks like protobuf only got mentioned in the table API section in the docs.

My bet it's using deserializer should work. https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/kafka/#deserializer