package de.juplo.kafka;
import org.apache.kafka.clients.consumer.ConsumerRecord;
-import org.apache.kafka.common.TopicPartition;
import java.util.function.Consumer;
-public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
+public interface RecordHandler
{
- default void beforeNextPoll() {}
-
- default void onPartitionAssigned(TopicPartition tp) {}
-
- default void onPartitionRevoked(TopicPartition tp) {}
+ void addNumber(
+ String topic,
+ Integer partition,
+ Long offset,
+ String user,
+ MessageAddNumber message);
+ void calculateSum(
+ String topic,
+ Integer partition,
+ Long offset,
+ String user,
+ MessageCalculateSum message);
}