[GitHub] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

[kchilton2]

Github user kchilton2 commented on a diff in the pull request:

    https://github.com/apache/incubator-rya/pull/272#discussion_r168276101
  
    --- Diff: 
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/KafkaTopics.java
 ---
    @@ -48,7 +51,28 @@
          */
         public static String queryChangeLogTopic(final String ryaInstance) {
             requireNonNull(ryaInstance);
    -        return ryaInstance + "-QueryChangeLog";
    +        return ryaInstance + QUERY_CHANGE_LOG_TOPIC_SUFFIX;
    +    }
    +
    +    /**
    +     * Get the Rya instance name from a Kafka topic name that has been 
used for a {@link QueryChnageLog}.
    --- End diff --
    
    Done.


---