Github user ejwhite922 commented on a diff in the pull request: https://github.com/apache/incubator-rya/pull/286#discussion_r178588294 --- 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"; --- End diff -- Maybe change to: = LogConfig.CleanupPolicyProp();
---