Skip to content

Commit dfb133b

Browse files
add index and shard details in dropped message log
Signed-off-by: Varun Bharadwaj <varunbharadwaj1995@gmail.com>
1 parent a5dd471 commit dfb133b

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

server/src/main/java/org/opensearch/indices/pollingingest/MessageProcessorRunnable.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -393,7 +393,13 @@ private void logDroppedMessage(ShardUpdateMessage shardUpdateMessage) {
393393
String id = shardUpdateMessage.autoGeneratedIdTimestamp() == UNSET_AUTO_GENERATED_TIMESTAMP
394394
? (String) shardUpdateMessage.parsedPayloadMap().get(ID)
395395
: "null";
396-
logger.warn("Exhausted retries, dropping message: _id:{}, pointer:{}", id, shardUpdateMessage.pointer().asString());
396+
logger.warn(
397+
"Exhausted retries, dropping message: Index={}, Shard={}, _id:{}, pointer:{}",
398+
indexName,
399+
shardId,
400+
id,
401+
shardUpdateMessage.pointer().asString()
402+
);
397403
}
398404

399405
/**

0 commit comments

Comments
 (0)