Use oldRow for delele change list
diff --git a/listener.go b/listener.go index 53d4bdd..f86b2ad 100644 --- a/listener.go +++ b/listener.go
@@ -79,7 +79,7 @@ log.Debugf("Refreshed local tenantCache. Added scope: %s", scopeuuid) } case common.Delete: - rows = append(rows, payload.NewRow) + rows = append(rows, payload.OldRow) // Lock before writing to the map as it has multiple readers tenantCachelock.Lock() defer tenantCachelock.Unlock()