Hi Users,

Is there a way that Flink 1.9 the checkpointed data can be read using the
state processor api.
Docs [1] says - When reading operator state, users specify the operator
uid, the state name, and the type information.

What is the type for the kafka operator, which needs to be specified while
reading the state.

[1] -
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/libs/state_processor_api/

Thanks,
Hemant

Reply via email to