Hello I'm using Kafka Streams and I have a transformer that uses a TimestampedKeyValueStore, I have a punctuator that is in charge of cleaning the store,
Basically I'm iterating the store using kvStore.all() and deleting the keys based on some logic with kvStore.delete(key); I'm seeing the changelog topic for the store grow unbounded, I'm seeing many values with null for the same keys... I think those are called tombstones right? but the punctuator is constantly doing the same thing trying to delete the same keys.. I see more tombstones being inserted. Is this the expected behavior? If so, how can I correctly clean that store? thanks - Miguel