X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FProduceFailure.java;h=7c78482c7bf3a81b7fd7061295c1d79d0916c382;hb=e09650509adafd0b28f141ea1302fa27ba69b73a;hp=873a67b46557b972cbe019997e9dc8c22beb33cb;hpb=6aa275cf310f594d3f86620fb9200591ebe11c75;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();