Estou testando o Consumidor de Alto Nível Kafka usando o código ConsumerGroupExample do site Kafka. Eu gostaria de recuperar todas as mensagens existentes no tópico chamado "teste" que tenho na configuração do servidor Kafka. Olhando para outros blogs, o auto.offset.reset deve ser definido como "menor" para poder receber todas as mensagens:

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

A questão que realmente tenho é: qual é a API Java equivalente chamada para o consumidor de alto nível que é equivalente a:

bin / kafka-console-consumer.sh --zookeeper localhost: 2181 - teste de tópico --de início