Hi, My data source is Kafka, all these days have been reading the values from Kafka stream to a table. The table just grows and runs into a heap issue.
Came across the eviction policy that works on only keys, right? Have researched to configure the environment file(Flink SLQ) to read both key and value, so as the eviction works on the keys and older data is cleared. I found nothing in the docs, so far. Could someone help with that? If there's no support for reading key and value, can someone help me to assign a key to the table I'm building from stream? Thanks Srikanth
