Hello, I am having a scenario where in flink kafka source (org.apache.flink.connector.kafka.source.KafkaSource) after fetching kafka record, there is need for OAuth authentication for one of the 3rd party REST API.
This API needs authentication token and has some expiry time associated with it and token refresh needs to be triggered after that much expiry time to avoid REST call per kafka record. So, is there any way to solve it without opening a separate thread for expiry time to count? Rgds, Kamal
