I've rebased on #5687 to pull in some logic changes that were a consequence of test feedback. Reminder: this code won't compile until #5687 is merged.
[ Full content available at: https://github.com/apache/kafka/pull/5688 ] This message was relayed via gitbox.apache.org for [email protected]
