code: private boolean isRequiredToUploadAtTime(TopicPartition topicPartition) throws Exception{
          final String topic = topicPartition.getTopic();
          if (mTopicFilter == null || mTopicFilter.isEmpty()){
              return false;
          }
          if (topic.matches(mTopicFilter)){
              if (DateTime.now().minuteOfHour().get() == mConfig.getUploadMinuteMark()){
                 return true;
              }
          }
          return false;
      }
docs: *
  If the topic is in the list of topics to upload at a specific time. For example at a minute mark.
  @param topicPartition
  @return
  @throws Exception