X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDriverController.java;h=ed3808068ffd3706dd57b4d5b7e45f1c260fdae6;hb=ce840f48340d55613291fca468bf10b834c473db;hp=93580eeb89aefe97dadea7c48d9334a44c1a2140;hpb=262d13bfa0274005b050c7b271f867acd9809f8b;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 93580ee..ed38080 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)