Ich teste den Kafka High Level Consumer mit dem ConsumerGroupExample-Code von der Kafka-Site. Ich möchte alle vorhandenen Nachrichten zum Thema "Test" abrufen, die ich in der Kafka-Serverkonfiguration habe. In anderen Blogs sollte auto.offset.reset auf "Kleinst" gesetzt sein, um alle Nachrichten abrufen zu können:

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

Die Frage, die ich wirklich habe, lautet: Was ist der entsprechende Java API-Aufruf für den High Level Consumer, der dem folgenden entspricht:

bin / kafka-console-consumer.sh --zookeeper localhost: 2181 --topic test --von anfang an