private final Consumer<String, MessageTo> consumer;
private final String topic;
// private final long[] offsets; Erst mal immer alles neu einlesen
private final Consumer<String, MessageTo> consumer;
private final String topic;
// private final long[] offsets; Erst mal immer alles neu einlesen