WIP:kafkahandler

[demos/kafka/training] / src / main / java / de / juplo / kafka / RecordHandler.java

package de.juplo.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.function.Consumer;


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);
}