Skip to content

Commit 416dd2e

Browse files
author
Om Shinde
committed
add info of commiting offsets in error log when it failed to commit
1 parent f27085c commit 416dd2e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ConsumerOffsetCommitter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ protected void commitOffsets(final Map<TopicPartition, OffsetAndMetadata> offset
9797
log.debug("Committing offsets Async");
9898
consumerMgr.commitAsync(offsetsToSend, (offsets, exception) -> {
9999
if (exception != null) {
100-
log.error("Error committing offsets", exception);
100+
log.error("Error committing offsets: {}, exception: ", offsets, exception);
101101
// todo keep work in limbo until async response is received?
102102
}
103103
});

0 commit comments

Comments
 (0)