+++ /dev/null
-package de.juplo.kafka;
-
-import org.apache.kafka.clients.consumer.ConsumerRecord;
-
-import java.util.function.Consumer;
-
-
-public interface RecordHandler
-{
- void addNumber(
- String topic,
- Integer partition,
- Long offset,
- String user,
- MessageAddNumber message);
- void calculateSum(
- String topic,
- Integer partition,
- Long offset,
- String user,
- MessageCalculateSum message);
-}