From 1c8500f98ca46f2de83989f96f2a273db3830f87 Mon Sep 17 00:00:00 2001
From: Aaron Pritzlaff <aaron.pritzlaff@gmail.com>
Date: Mon, 30 Mar 2020 14:28:04 +0100
Subject: [PATCH] removed topic filtering from poll

---
 src/main/scala/kafka4m/consumer/RichKafkaConsumer.scala | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/src/main/scala/kafka4m/consumer/RichKafkaConsumer.scala b/src/main/scala/kafka4m/consumer/RichKafkaConsumer.scala
index d6196ff..511bfee 100644
--- a/src/main/scala/kafka4m/consumer/RichKafkaConsumer.scala
+++ b/src/main/scala/kafka4m/consumer/RichKafkaConsumer.scala
@@ -74,11 +74,7 @@ final class RichKafkaConsumer[K, V] private (val consumer: KafkaConsumer[K, V],
     try {
       val records: ConsumerRecords[K, V] = consumer.poll(timeout)
       logger.debug(s"Got ${records.count()} records from ${records.partitions().asScala.mkString(s"[", ",", "]")}")
-      val forTopic: Iterable[ConsumerRecord[K, V]] = {
-        records.asScala.filter { record =>
-          topics.contains(record.topic())
-        }
-      }
+      val forTopic: Iterable[ConsumerRecord[K, V]] = records.asScala
       logger.trace(s"Got ${forTopic.size} of ${records.count()} for topic '$topics' records from ${records.partitions().asScala.mkString(s"[", ",", "]")}")
       forTopic
     } catch {