{
private final AdderResults results;
private final Optional<Duration> throttle;
+ private final String id;
private final Map<Integer, AdderBusinessLogic> state = new HashMap<>();
String user = record.key();
String message = record.value();
+ if (!state.containsKey(partition))
+ state.put(partition, new AdderBusinessLogic());
+
if (message.equals("CALCULATE"))
{
AdderResult result = state.get(partition).calculate(user);
- log.info("New result for {}: {}", user, result);
+ log.info("{} - New result for {}: {}", id, user, result);
results.addResults(partition, user, result);
}
else
}
catch (InterruptedException e)
{
- log.warn("Intrerrupted while throttling: {}", e);
+ log.warn("{} - Intrerrupted while throttling: {}", id, e);
}
}
}