[KAFKA-4558] throttling_test fails if the producer starts too fast.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.10.2.0
• Assignee: Apurva Mehta
• Reporter: Apurva Mehta
• Created: 19/Dec/16 23:12
• Updated: 05/Feb/17 10:33
• Resolved: 05/Feb/17 10:33

Description

As described in https://issues.apache.org/jira/browse/KAFKA-4526, the throttling test will fail if the producer in the produce-consume-validate loop starts up before the consumer is fully initialized.

We need to block the start of the producer until the consumer is ready to go.

The current plan is to poll the consumer for a particular metric (like, for instance, partition assignment) which will act as a good proxy for successful initialization. Currently, we just check for the existence of a process with the PID, which is not a strong enough check, causing the test to fail intermittently.