Description
When a kafka client produces ~30k events and at the end it aborts the transaction a consumer can read part of the aborted messages when "isolation.level" set to "READ_COMMITTED".
Kafka client version: 2.0.0
Kafka broker version: 1.0.0
Producer:
java -jar kafka-producer/target/kafka-producer-0.0.1-SNAPSHOT-jar-with-dependencies.jar gsomogyi-cdh5144-220cloudera2-1.gce.cloudera.com:9092 src-topic
See attached code.
Consumer:
kafka-console-consumer --zookeeper localhost:2181 --topic src-topic --from-beginning --isolation-level read_committed
Same behavior seen when re-implemented the consumer in scala.
The whole application can be found here: https://github.com/gaborgsomogyi/kafka-semantics-tester