We are doing some chaos testing where we are feeding data to Kafka brokers through rest proxy and then suddenly stopping the brokers etc and checking the failover time.
Some behaviour that I am observing is sometimes during the test we have missing messages. The rest proxy is giving us 200 but the messages are not produced in the topic.
We are using acks=all.
How can we change the behaviour of rest proxy where if it fails producing to topic it returns a non 200 status code so that the non Java producer can retry.