I've set a few custom keys in the Kafka headers
timeStamp:<current date>
myKey1:1
This is my KTABLE
KTable<String, String> table1=streamsBuilder.table("MYTOPIC");
I need to filter this table based on the header's key timeStamp
. How to achieve this, since KTable<String,String>
, the key is only the kafka message key
. How to filter the records based on the header keys.