我有一个用例，其中我有一个消息，必须推送到Kafka的一些主题。目前在较高级别上，该方法如下所示：

pushToTopics(String msg){
  pushToTopicA(msg);
  pushToTopicB(msg);
  pushToTopicC(msg);
  .
  .
  .
  pushToTopicN(msg);
}

每个pushtotopopicx（msg）都有一个条件，当满足该条件时，应该将消息发布到相应的主题。现在，所有这些逻辑都在终端螺栓上，为了推送消息，我们使用kafkaproducer。
我正在研究如何将其分解为特定主题的螺栓，更重要的是使用kafkabolts来推送消息。
风暴（1.2.2版）有可能吗？我最近看到一个pr被合并了，它可以创建自定义回调，但是我们没有。