X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FProduceFailure.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FProduceFailure.java;h=7c78482c7bf3a81b7fd7061295c1d79d0916c382;hb=96013a5bc40a65eb35713bccc756eea03c4f3de7;hp=873a67b46557b972cbe019997e9dc8c22beb33cb;hpb=459f64072f3b657990a3bda0d39306208702d537;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ProduceFailure.java b/src/main/java/de/juplo/kafka/ProduceFailure.java
index 873a67b..7c78482 100644
--- a/src/main/java/de/juplo/kafka/ProduceFailure.java
+++ b/src/main/java/de/juplo/kafka/ProduceFailure.java
@@ -12,7 +12,7 @@ public class ProduceFailure implements ProduceResult
   private final Integer status;
 
 
-  public ProduceFailure(Exception e)
+  public ProduceFailure(Throwable e)
   {
     status = 500;
     exception = e.getClass().getSimpleName();