Re: Reading KafkaSource state from a savepoint using the State Processor API

2023-05-24 Thread Hang Ruan
Hi, Charles, I am used to read the state in the debug mode. I always set the breakpoint at the return statemnet in `SavepointReader#read`. Then I could find the state I need in the field `SavepointMetadataV2 savepointMetadata`. Finally I could deserialize the state bytes with

Reading KafkaSource state from a savepoint using the State Processor API

2023-05-23 Thread Charles Tan
Hi everyone, I have a few questions about reading KafkaSource state using the State Processor API. I have a simple Flink application which reads from a Kafka topic then produces to a different topic. After running the Flink job and stopping it with a savepoint, I then write a few more records to