This may have to do with Statistics not being written on flush - needs further investigation. I recommend using BasicKafkaIT to test this.
This may have to do with Statistics not being written on flush - needs further investigation. I recommend using BasicKafkaIT to test this.