[
https://issues.apache.org/jira/browse/RYA-467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16422799#comment-16422799
]
ASF GitHub Bot commented on RYA-467:
------------------------------------
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/286#discussion_r178586989
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/interactor/KafkaTopicPropertiesBuilder.java
---
@@ -0,0 +1,46 @@
+package org.apache.rya.streams.kafka.interactor;
+
+import static java.util.Objects.requireNonNull;
+
+import java.util.Optional;
+import java.util.Properties;
+
+/**
+ * Properties builder to be used when creating new Kafka Topics.
+ *
+ * Descriptions of properties can be found at
+ * {@link https://kafka.apache.org/documentation/#topicconfigs}
+ */
+public class KafkaTopicPropertiesBuilder {
+ /*----- Cleanup Policy -----*/
+ public static final String CLEANUP_POLICY_KEY = "cleanup.policy";
+ public static final String CLEANUP_POLICY_DELETE = "cleanup.policy";
--- End diff --
Change to:
= "delete";
or
= LogConfig.Delete();
> Rya Streams - QueryChangeLog topic deletes content after 7 days.
> ----------------------------------------------------------------
>
> Key: RYA-467
> URL: https://issues.apache.org/jira/browse/RYA-467
> Project: Rya
> Issue Type: Bug
> Reporter: Kevin Chilton
> Assignee: Eric White
> Priority: Major
>
> The automatically created topic used as the QueryChangeLog for a rya instance
> uses the default "cleanup.policy" or "delete", and it does it after 7 days.
> The policy for that topic should be "compact" since the query change log
> needs to persist forever.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
