Nice clean-up! One remaining item that didn't look nice was the `Option.get` calls after `getPartition`. I submitted a tiny clean-up for that:
https://github.com/apache/kafka/pull/5598/files [ Full content available at: https://github.com/apache/kafka/pull/5587 ] This message was relayed via gitbox.apache.org for [email protected]
