Wei Song created SAMZA-1929:
-------------------------------

             Summary: Expose Kafka topic level configuration in local store 
backed table descriptors
                 Key: SAMZA-1929
                 URL: https://issues.apache.org/jira/browse/SAMZA-1929
             Project: Samza
          Issue Type: New Feature
          Components: kv-store
            Reporter: Wei Song


The changelog Kafka topic level configuration may be useful for adjustment, 
when TTL is set on a RocksDB store or when enabled for in-memory DB. User 
should be able to set Kafka topic level properties as follows

TableDescriptor desc = new RocksDbTableDescriptor(...)
    .withChangelogKafkaTopicLevelProperty("cleanup.policy", "delete")
    .withChangelogKafkaTopicLevelProperty("retention.ms", "3600");

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to