import java.util.function.Consumer;
-public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
+public interface RecordHandler
{
- default void beforeNextPoll() {}
+ void addNumber(
+ String topic,
+ Integer partition,
+ Long offset,
+ String user,
+ MessageAddNumber message);
+ void calculateSum(
+ String topic,
+ Integer partition,
+ Long offset,
+ String user,
+ MessageCalculateSum message);
}