How can I force the deletion of a record within a very small amount of time?  
That seems possible only by adding a bunch of records to the topic to force the 
segment containing the Tombstone record to become inactive.  I need better 
control of my data so I can guarantee record deletes and updates.

Here’s my topic:
kafka-topics --zookeeper 127.0.0.1:2181 --create --partitions 1 
--replication-factor 1 --config cleanup.policy=compact --config 
min.cleanable.dirty.ratio=0.00001 —-config 
log.cleaner.io.max.bytes.per.second=1000000 --topic cc-search13 --config 
segment.ms=1000 --config delete.retention.ms=0 --config min.compaction.lag.ms=0

I am waiting several seconds before querying the topic (via Landoop).

Thanks in advance —

Cindy

Reply via email to