Not 100% sure. From what you describe it should work as expected.
It seems `delete()` does not delete the key from the store (ie, RocksDB) itself (for unknown reasons)?
Are you closing all your iterators correctly? (More or less a wild guess at the moment.)
Did you enable caching for the store? (Just to double check if it could be caching related or not.)
-Matthias On 12/24/21 11:08 AM, Miguel González wrote:
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
