From d65ef8edb6d4f26f156319b416ce553503b559cb Mon Sep 17 00:00:00 2001
From: "amitav.mohanty" <amitavmohanty01@gmail.com>
Date: Thu, 31 Oct 2019 00:18:39 +0530
Subject: [PATCH] Mention the path of DLQ to indicate DLQ if full for which
 pipeline

Fixes #11280
---
 .../main/java/org/logstash/common/io/DeadLetterQueueWriter.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java b/logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java
index bc333bc70..d9159e201 100644
--- a/logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java
+++ b/logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java
@@ -131,7 +131,7 @@ public final class DeadLetterQueueWriter implements Closeable {
         byte[] record = entry.serialize();
         int eventPayloadSize = RECORD_HEADER_SIZE + record.length;
         if (currentQueueSize.longValue() + eventPayloadSize > maxQueueSize) {
-            logger.error("cannot write event to DLQ: reached maxQueueSize of " + maxQueueSize);
+            logger.error("cannot write event to DLQ(path: " + this.queuePath + "): reached maxQueueSize of " + maxQueueSize);
             return;
         } else if (currentWriter.getPosition() + eventPayloadSize > maxSegmentSize) {
             currentWriter.close();