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

Reply via email to