<Apache Kafka exactly once implementation not work...

# stackoverflow

[rss]

Apache Kafka exactly once implementation not working
I'm implementing a exactly-once implementation using a consumer and producer with the Apache Kafka Java clients, but I don't manage to make it work.
Below is the minimal implementation that simulates stopping the processing of a batch mid way a few times before finishing.
package com.topictale.base.kafka.examples

import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.clients.consumer.OffsetAndMetadata
import org.apache.kafka.clients.producer.KafkaProducer
import...