title: Kafka High Level Consumer Fetch All Messages From Topic Using Java API (Equivalent to --from-beginning)
body: <p>I am testing the Kafka High Level Consumer using the ConsumerGroupExample code from the Kafka site.  I would like to retrieve all the existing messages on the topic called "test" that I have in the Kafka server config.  Looking at other blogs, auto.offset.reset should be set to "smallest" to be able to get all messages: </p>
  
  <pre><code>private static ConsumerConfig createConsumerConfig(String a_zookeeper, String a_groupId)    {
      Properties props = new Properties();
      props.put("zookeeper.connect", a_zookeeper);
      props.put("group.id", a_groupId);
      props.put("auto.offset.reset", "smallest");
      props.put("zookeeper.session.timeout.ms", "10000");     
  
      return new ConsumerConfig(props);
  }
  </code></pre>
  
  <p>The question I really have is this: what is the equivalent Java api call for the High Level Consumer that is the equivalent of:</p>
  
  <p>bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning</p>