Enable ssl authentication in kafka client

Hello all, I am looking for some pointers to securely connect to kakfa source from a AWS Kinesis Data Analytics Flink application. I found a workaround here, but I was wondering if there was any alternate approach discussed in the flink co

RocksDB Compaction filter to clean up state with TTL

Hello, Flink 1.8 introduces the config ‘state.backend.rocksdb.ttl.compaction.filter.enabled’ to enable or disable the compaction filter to cleanup state with TTL. I was curious why its disabled by default. Are there any performance implications of turning it ON by default? Thanks, Abhilasha