1 package de.juplo.kafka;
8 public class ProduceFailure implements ProduceResult
10 private final String[] error;
11 private final String[] exception;
12 private final Integer status;
15 public ProduceFailure(Exception[] e)
18 exception = new String[e.length];
19 error = new String[e.length];
20 for (int i = 0; i < e.length ; i++)
22 exception[i] = e[i] == null ? null : e[i].getClass().getSimpleName();
23 error[i] = e[i] == null ? null : e[i].getMessage();