You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Wei Song (JIRA)" <ji...@apache.org> on 2018/10/01 23:45:00 UTC

[jira] [Created] (SAMZA-1929) Expose Kafka topic level configuration in local store backed table descriptors

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)