Die Implementierung speichert Zustand & Offsets vor _jedem_ `poll()`

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

package de.juplo.kafka;

import lombok.Getter;
import lombok.RequiredArgsConstructor;

import java.util.Map;


@RequiredArgsConstructor
@Getter
public class ApplicationState
{
  private final Long offset;
  private final Map<String, AdderResult> adderState;
}