code: public boolean seekToEnd(String topic) {
          KafkaConsumer<?, ?> consumer = _getConsumer(topic);
          return KafkaHelper.seekToEnd(consumer, topic);
      }
docs: Seeks to the end of all assigned partitions of a topic.
  
  @param topic
  @return {@code true} if the consumer has subscribed to the specified
  topic, {@code false} otherwise.
  @since 1.2.0