projects
/
demos
/
kafka
/
training
/ blob
commit
grep
author
committer
pickaxe
?
search:
re
47f984effad4720fd525dabff77d464e040d320e
[demos/kafka/training]
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
RecordHandler.java
1
package de.juplo.kafka;
2
3
import org.apache.kafka.clients.consumer.ConsumerRecord;
4
5
import java.util.function.Consumer;
6
7
8
public interface RecordHandler
9
{
10
void addNumber(
11
String topic,
12
Integer partition,
13
Long offset,
14
String user,
15
MessageAddNumber message);
16
void calculateSum(
17
String topic,
18
Integer partition,
19
Long offset,
20
String user,
21
MessageCalculateSum message);
22
}