How to reproduce it (as minimally and precisely as possible)
create java web application to produce 1 kafka message per second
create kafka 10s delay with chaosblade which deploy on the virtual machine same as java web application
start kafka consumer to consume the message
Result
before create delay, consumer comsume 1msg /second , after create delay , comsume 1msg second per 10 seconds, comsumer can't consumer the other 9 msg. delay take effect but some msg loss
Describe what happened (or what feature you want)
Describe what you expected to happen
consumer can comsume all msg, 1msg /second , consumer the msg which is produced 10s berfore
Tell us your environment
chaosblade 1.3.0 or 1.6.1
java 8
kafka client 0.10.2.1
Issue Description
Type: bug report
How to reproduce it (as minimally and precisely as possible)
Result
before create delay, consumer comsume 1msg /second , after create delay , comsume 1msg second per 10 seconds, comsumer can't consumer the other 9 msg. delay take effect but some msg loss
Describe what happened (or what feature you want)
Describe what you expected to happen
consumer can comsume all msg, 1msg /second , consumer the msg which is produced 10s berfore
Tell us your environment
chaosblade 1.3.0 or 1.6.1 java 8 kafka client 0.10.2.1
Anything else we need to know?