I need to be specific with my comments :) I'm suggesting sth like `records.records(topicPartition).stream().filter().collect()`, the main point is that `ConsumerRecords#iterate` which is used as `final ConsumerRecord<byte[], byte[]> record : records` is a pretty complex operator and is unnecessary here since we know it will only contain one topic-partition.
[ Full content available at: https://github.com/apache/kafka/pull/5710 ] This message was relayed via gitbox.apache.org for [email protected]
