// tag::create[]
Properties props = new Properties();
props.put("bootstrap.servers", ":9092");
- props.put("group.id", "my-consumer"); // << Used for Offset-Commits
+ props.put("group.id", "my-consumer"); // << Used for Offset-Management
// end::create[]
props.put("auto.offset.reset", "earliest");
// tag::create[]
{
log.info("{} - Closing the KafkaConsumer", id);
consumer.close();
- log.info("C - DONE!");
+ log.info("{} - DONE!");
stopped.signal();
}
finally