From b1e975298670055b0565f2c53868522bf5173a8c Mon Sep 17 00:00:00 2001 From: Kegan Dougal Date: Fri, 10 Mar 2017 15:42:04 +0000 Subject: [PATCH] Use the event ID as the key for de-dupe --- .../matrix-org/dendrite/clientapi/writers/createroom.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/github.com/matrix-org/dendrite/clientapi/writers/createroom.go b/src/github.com/matrix-org/dendrite/clientapi/writers/createroom.go index 02588d328..cf78ac7d7 100644 --- a/src/github.com/matrix-org/dendrite/clientapi/writers/createroom.go +++ b/src/github.com/matrix-org/dendrite/clientapi/writers/createroom.go @@ -274,7 +274,7 @@ func eventsToMessages(events []*gomatrixserverlib.Event) ([]*sarama.ProducerMess return nil, err } m.Topic = "clientapiOutput" // TODO: Make this customisable like roomserver is? - m.Key = sarama.StringEncoder("") + m.Key = sarama.StringEncoder(e.EventID()) m.Value = sarama.ByteEncoder(value) msgs[i] = &m }