diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java index 80372cbc7cfe1..b174bc547d7f5 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java @@ -229,8 +229,8 @@ private void completeFutureAndFireCallbacks(long baseOffset, long logAppendTime, if (thunk.callback != null) thunk.callback.onCompletion(null, exception); } - } catch (Exception e) { - log.error("Error executing user-provided callback on message for topic-partition '{}'", topicPartition, e); + } catch (Throwable t) { + log.error("Error executing user-provided callback on message for topic-partition '{}'", topicPartition, t); } }