Kafka - Advanced Stream Processing
Given this Kafka Streams code snippet, what is the output if a failure occurs before commit?
StreamsBuilder builder = new StreamsBuilder(); KStreamstream = builder.stream("input-topic"); stream.mapValues(value -> value.toUpperCase()) .to("output-topic"); props.put("processing.guarantee", "exactly_once"); KafkaStreams streams = new KafkaStreams(builder.build(), props); streams.start(); // Failure happens before commit
