class SourceTopicsExtractor extends DefaultTraversalVisitor<AstNode, Void> {

  public String getPrimaryKafkaTopicName() {
    return primaryKafkaTopicName;
  }

  public  SourceTopicsExtractor(final MetaStore metaStore);

}