juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/ProduceFailure.java

   1 package de.juplo.kafka;
   2
   3
   4 import lombok.Value;
   5
   6
   7 @Value
   8 public class ProduceFailure implements ProduceResult
   9 {
  10   private final String error;
  11   private final String exception;
  12   private final Integer status;
  13
  14
  15   public ProduceFailure(Throwable e)
  16   {
  17     status = 500;
  18     exception = e.getClass().getSimpleName();
  19     error = e.getMessage();
  20   }
  21 }