diff --git a/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ConsumerOffsetCommitter.java b/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ConsumerOffsetCommitter.java index 1c3d5de10..b0464b138 100644 --- a/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ConsumerOffsetCommitter.java +++ b/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ConsumerOffsetCommitter.java @@ -97,7 +97,7 @@ protected void commitOffsets(final Map offset log.debug("Committing offsets Async"); consumerMgr.commitAsync(offsetsToSend, (offsets, exception) -> { if (exception != null) { - log.error("Error committing offsets", exception); + log.error("Error committing offsets: {}, exception: ", offsets, exception); // todo keep work in limbo until async response is received? } });