Hello, @mjsax Looks like a didn't understand initial task properly :) Thank you for the clarification!
1. `waitOnState` reworked. 2. Tests added. 3. Current methods behaviour preserved. Please, take a look. [ Full content available at: https://github.com/apache/kafka/pull/5747 ] This message was relayed via gitbox.apache.org for devnull@infra.apache.org
