LastOffsetPerPartition.java

    List<ConsumerRecord<byte[], byte[]>> lastRecords = new ArrayList<>();
    try (KafkaConsumer<byte[], byte[]> consumer = new KafkaConsumer<>(consumerProps)) {
      for (PartitionInfo info : consumer.partitionsFor(topic)) {
        List<TopicPartition> list = new ArrayList<>();
        list.add(new TopicPartition(topic, info.partition()));
        consumer.assign(list);
        consumer.seekToEnd(list);
        ConsumerRecord<byte[], byte[]> last = consumer.poll(10000).iterator().next();
        lastRecords.add(last);
      }
    }
    lastRecords.stream().sorted((r1,r2) -> r1.partition() - r2.partition())
    .forEach(r -> {
      System.out.println(r.partition() + " " + r.offset() + " " + new Date(r.timestamp()));
    });