in src/com/epam/digital/data/platform/pipelines/registrycomponents/regular/Kafka.groovy [44:52]
private String getKafkaTopics() {
String kafkaTopicsTmp = ''
kafkaTopicList.each { kafkaTopic ->
if ((kafkaTopic.contains("inbound") || kafkaTopic.contains("outbound"))) {
kafkaTopicsTmp = kafkaTopicsTmp + "$kafkaTopic,"
}
}
return kafkaTopicsTmp
}