Estoy probando el consumidor de alto nivel de Kafka usando el código ConsumerGroupExample del sitio de Kafka. Me gustaría recuperar todos los mensajes existentes sobre el tema llamado "prueba" que tengo en la configuración del servidor Kafka. Al mirar otros blogs, auto.offset.reset debe establecerse en "más pequeño" para poder obtener todos los mensajes:

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);
}

La pregunta que realmente tengo es esta: ¿cuál es la llamada API equivalente de Java para el consumidor de alto nivel que es el equivalente de:

bin / kafka-console-consumer.sh --zookeeper localhost: 2181 - prueba de tema --desde el comienzo