[hotfix] Modify internal topic name
@@ -23,6 +23,10 @@ import org.apache.commons.lang3.RandomStringUtils;
public class TopicGenerator {
public static String generateRandomTopic() {
- return "org.apache.streampipes." + RandomStringUtils.randomAlphabetic(20);
+ return generateInternalPipelineElementTopic(RandomStringUtils.randomAlphabetic(15));
+ }
+
+ public static String generateInternalPipelineElementTopic(String appendix) {
+ return "org-apache-streampipes-internal-" + appendix;
}
}
