Skip to content

Commit f54e0d5

Browse files
OmShinde1513Om Shinde
andauthored
add info of commiting offsets in error log when it failed to commit (#850)
Co-authored-by: Om Shinde <oshinde@ptc.com>
1 parent 1c4bc0b commit f54e0d5

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

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)