X-Git-Url: https://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=d0de5c9030e575251d62d2a207ede84cd881ccec;hp=873a67b46557b972cbe019997e9dc8c22beb33cb;hpb=f348b232d39c0b03f21a4d1e083fc6f2b44468f0;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();