Kafka - Consumers
Given the following Kafka consumer code snippet with auto-commit enabled:
What happens if the consumer crashes immediately after this code runs?
Properties props = new Properties();
props.put("enable.auto.commit", "true");
props.put("auto.commit.interval.ms", "1000");
KafkaConsumer consumer = new KafkaConsumer<>(props);
consumer.subscribe(List.of("topic1"));
ConsumerRecords records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord record : records) {
System.out.println(record.value());
} What happens if the consumer crashes immediately after this code runs?
