aboutsummaryrefslogtreecommitdiff
path: root/federationsender
diff options
context:
space:
mode:
authorNeil Alexander <neilalexander@users.noreply.github.com>2021-01-18 12:58:48 +0000
committerNeil Alexander <neilalexander@users.noreply.github.com>2021-01-18 12:58:48 +0000
commit534c29ab02e4566712bcc7eb9912b1a7a21e0ae4 (patch)
tree29032f7298a99e396ee43c59b1112ef03b91cfdd /federationsender
parentefc91146f0476239ac737c37ae8822346c415014 (diff)
Log event ID on consumer errors (fixes #1714)
Diffstat (limited to 'federationsender')
-rw-r--r--federationsender/consumers/roomserver.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/federationsender/consumers/roomserver.go b/federationsender/consumers/roomserver.go
index b53cb251..513919c6 100644
--- a/federationsender/consumers/roomserver.go
+++ b/federationsender/consumers/roomserver.go
@@ -102,6 +102,7 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error {
default:
// panic rather than continue with an inconsistent database
log.WithFields(log.Fields{
+ "event_id": ev.EventID(),
"event": string(ev.JSON()),
"add": output.NewRoomEvent.AddsStateEventIDs,
"del": output.NewRoomEvent.RemovesStateEventIDs,