org.apache.spark.sql.kafka010.KafkaDontFailOnDataLossSuite

failOnDataLoss=false should not return duplicated records: batch

failOnDataLoss=false should not return duplicated records: batch v1

failOnDataLoss=false should not return duplicated records: batch v2

failOnDataLoss=false should not return duplicated records: continuous processing

failOnDataLoss=false should not return duplicated records: microbatch v1

failOnDataLoss=false should not return duplicated records: microbatch v2

failOnDataLoss=false should not return duplicated records: v1

failOnDataLoss=false should not return duplicated records: v2