Enrichment with keyed state as cache

Hi, We're building a Flink job to process metric data from client devices. We need to enrich these events via an external HTTP API. We were thinking we'd use Flink state as a cache of this enrichment data to reduce the load on the external service. It seems AsyncFunctions do not support keyed st

Unit testing KeyedProcessFunction that uses async state

Hi, I'm attempting to unit test a KeyedProcessFunction that uses v2 Async State API using "ProcessFunctionTestHarnesses.forKeyedProcessFunction()". When I run my test it fails with: "Caused by: java.lang.IllegalStateException: Current operator integrates the async processing logic, thus only sup