X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDriverController.java;h=1fb2a1b5827083646e280418ef8b22c80f87b9fd;hb=7d46d2df2b323e0f4df2e7b5f15706840de4b804;hp=1525f5af73c346e2232a28e687ce79f81250a2b6;hpb=02cbeb117e64de32b246916072570e5b6598f745;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/DriverController.java b/src/main/java/de/juplo/kafka/DriverController.java index 1525f5a..1fb2a1b 100644 --- a/src/main/java/de/juplo/kafka/DriverController.java +++ b/src/main/java/de/juplo/kafka/DriverController.java @@ -31,12 +31,14 @@ public class DriverController consumer.stop(); } + @GetMapping("seen") public Map> seen() { return consumer.getSeen(); } + @ExceptionHandler @ResponseStatus(HttpStatus.BAD_REQUEST) public ErrorResponse illegalStateException(IllegalStateException e)