{
consumed++;
log.info("{} - partition={}-{}, offset={}: {}={}", id, topic, partition, offset, key, value);
+ switch (value.getType())
+ {
+ case ADD -> addNumber((MessageAddNumber)value);
+ case CALC -> calcSum((MessageCalculateSum)value);
+ default -> log.error("{} - Ignoring message of unknown typ {}", id, value.getType());
+ }
}
+ private void addNumber(MessageAddNumber addNumber)
+ {
+ log.info("{} - Adding number {}", id, addNumber.getNext());
+ }
+
+ private void calcSum(MessageCalculateSum calculateSum)
+ {
+ log.info("{} - Calculating sum", id);
+ }
public void shutdown() throws InterruptedException
{