I think this is what I've done in the most recent version of the code: https://github.com/apache/kafka/pull/5710/files#diff-e870eab2dedeee93442ba87dc12609a4R277 ``` for (final ConsumerRecord<byte[], byte[]> record : records.records(topicPartition)) { if (record.key() != null) { restoreRecords.add(record); } } ``` Is that what you're thinking?
[ Full content available at: https://github.com/apache/kafka/pull/5710 ] This message was relayed via gitbox.apache.org for [email protected]
