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(Exception[] e)
  16   {
  17     status = 500;
  18     exception = new String[e.length];
  19     error = new String[e.length];
  20     for (int i = 0; i < e.length ; i++)
  21     {
  22       exception[i] = e[i] == null ? null : e[i].getClass().getSimpleName();
  23       error[i] = e[i] == null ? null : e[i].getMessage();
  24     }
  25   }
  26 }