github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 14:47:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Mention the path of DLQ to indicate DLQ if full for which pipeline

Browse source 
Fixes #11280
This commit is contained in:
amitav.mohanty 2019-10-31 00:18:39 +05:30 • committed by Andrea Selva
parent 9197bf221f
commit d65ef8edb6
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -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();