Skip to content

Commit 3dd117a

Browse files
amitavmohanty01andsel
authored andcommitted
Mention the path of DLQ to indicate DLQ if full for which pipeline
Fixes #11280
1 parent 81e7b18 commit 3dd117a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ private void innerWriteEntry(DLQEntry entry) throws IOException {
131131
byte[] record = entry.serialize();
132132
int eventPayloadSize = RECORD_HEADER_SIZE + record.length;
133133
if (currentQueueSize.longValue() + eventPayloadSize > maxQueueSize) {
134-
logger.error("cannot write event to DLQ: reached maxQueueSize of " + maxQueueSize);
134+
logger.error("cannot write event to DLQ(path: " + this.queuePath + "): reached maxQueueSize of " + maxQueueSize);
135135
return;
136136
} else if (currentWriter.getPosition() + eventPayloadSize > maxSegmentSize) {
137137
currentWriter.close();

0 commit comments

Comments
 (0)