Skip to content

Commit f005830

Browse files
authored
Merge pull request #3 from ballard26/additional-produce-log
Log error for produce failures
2 parents dd7dce4 + a681399 commit f005830

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -748,7 +748,7 @@ func produceInner(n int64, nPartitions int32, validOffsets *TopicOffsetRanges, s
748748
log.Debugf("Writing partition %d at %d", r.Partition, nextOffset[p])
749749
handler := func(r *kgo.Record, err error) {
750750
concurrent.Release(1)
751-
Chk(err, "Produce failed!")
751+
Chk(err, "Produce failed: %v", err)
752752
if expect_offset != r.Offset {
753753
log.Warnf("Produced at unexpected offset %d (expected %d) on partition %d", r.Offset, expect_offset, r.Partition)
754754
status.OnBadOffset()

0 commit comments

Comments
 (0)