0

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.

OneCricketeer
  • 179,855
  • 19
  • 132
  • 245
dark ninja
  • 33
  • 5

0 Answers0