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 = e.getClass().getSimpleName();
19 error = e.getMessage();