Service ergänzt, der das Dead-Letter-Topic ausliest

[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
{
  void addNumber(
      String topic,
      Integer partition,
      Long offset,
      String user,
      MessageAddNumber message);
  void calculateSum(
      String topic,
      Integer partition,
      Long offset,
      String user,
      MessageCalculateSum message);
}