consumer commit

consumer_commit.java

try {
  while (running) {
  ConsumerRecords<String, String> records = consumer.poll(1000);

  try {
    for (ConsumerRecord<String, String> record : records)
      // Your work here.
    } catch (CommitFailedException e) {
      // application specific failure handling
    }
    consumer.commitSync(); // THATS IT!
  }
} finally {
  consumer.close();
}