У меня есть сценарий использования, когда мне нужно «объединить» несколько тем Kafka на основе некоторых критериев в StreamSets Data Collector. Интересно, есть ли какая-то общепринятая идиома, которая могла бы решить такую проблему?