I have incoming messages from Kafka stream, incoming messages from topic contains a headers. I'm trying to process, store them into Kafka's TimestampedKeyValueStore and then forvard those messages further. ATP they are processed correctly, but they are stored without the headers, probably bcs of default serde. I have created new class based on kafka's ValueAndTimestamp, but I have also included headers as byte[]. My questions are, is it possible to store a such custom class and if yes, what does it require?
Yes - A custom class is stored by a Serde.
Yes - the Store interface can be replaced with your own implementation.