props.put("group.id", groupId);
props.put("client.id", id);
props.put("auto.offset.reset", autoOffsetReset);
+ props.put("metadata.max.age.ms", "1000");
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());
);
Integer partition = record.partition();
- String key = record.key();
+ String key = record.key() == null ? "NULL" : record.key();
if (!seen.containsKey(partition))
seen.put(partition, new HashMap<>());