log length of hashset

Signed-off-by: Sebastian Schüpbach <sebastian.schuepbach@unibas.ch>

src/main/scala/ch/memobase/App.scala

 /*
  * Import Process Delete
- * Copyright (C) 2020 Memoriav
+ * Copyright (C) 2021 Memoriav
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -54,7 +54,13 @@ object App
                 }
               }
               .filter(record => filters.forall(f => f(record)))
-              .foldLeft(HashSet[DeleteMessage]())((agg, record) => agg + DeleteMessage(record, sessionId))
+              .foldLeft(HashSet[DeleteMessage]())((agg, record) => {
+                logger.info(s"Length of delete messages: ${agg.size}")
+                agg + DeleteMessage(record, sessionId)
+              }
+
+              )
+
           )
           .foreach(id => sendDelete(id, dryRun))
       } catch {

src/main/scala/ch/memobase/AppSettings.scala

@@ -44,7 +44,7 @@ trait AppSettings {
     props.put("group.id", clientId)
     props.put("allow.auto.create.topics", "false")
     props.put("auto.offset.reset", "earliest")
-    props.put("max.poll.records", "500")
+    props.put("max.poll.records", "5000")
     props
   }
 }