Integer partition = record.partition();
String key = record.key() == null ? "NULL" : record.key();
Map<String, Long> byKey = seen.get(partition);
Integer partition = record.partition();
String key = record.key() == null ? "NULL" : record.key();
Map<String, Long> byKey = seen.get(partition);