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