I'm sorry; I didn't follow this. Are you suggesting to do `final List<ConsumerRecord<byte[], byte[]>> restoreRecords = records.records(topicPartition)`?
This would return the right type, but `restoreRecords` is a filtered list of only records with non-null keys. It doesn't look like `ConsumerRecords#records` applies this filter. [ Full content available at: https://github.com/apache/kafka/pull/5710 ] This message was relayed via gitbox.apache.org for [email protected]
