1 package de.juplo.kafka;
3 import lombok.EqualsAndHashCode;
5 import lombok.RequiredArgsConstructor;
6 import lombok.ToString;
9 @RequiredArgsConstructor
11 @EqualsAndHashCode(of = { "key" })
13 public class KeyCounter
15 private final String key;
17 private long result = 0;
20 public long increment()