diff --git a/src/net/KNet/Specific/Replicator/KNetCompactedReplicator.cs b/src/net/KNet/Specific/Replicator/KNetCompactedReplicator.cs
index 6980f23f2c..4cc9b4d11e 100644
--- a/src/net/KNet/Specific/Replicator/KNetCompactedReplicator.cs
+++ b/src/net/KNet/Specific/Replicator/KNetCompactedReplicator.cs
@@ -102,6 +102,11 @@ public interface IKNetCompactedReplicator<TKey, TValue> : IDictionary<TKey, TVal
     {
         #region Events
 
+        /// <summary>
+        /// Called when a [<typeparamref name="TKey"/>, <typeparamref name="TValue"/>] is added by consuming data from the others <see cref="IKNetCompactedReplicator{TKey, TValue}"/>
+        /// </summary>
+        event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnRemoteAdd;
+
         /// <summary>
         /// Called when a [<typeparamref name="TKey"/>, <typeparamref name="TValue"/>] is updated by consuming data from the others <see cref="IKNetCompactedReplicator{TKey, TValue}"/>
         /// </summary>
@@ -112,6 +117,11 @@ public interface IKNetCompactedReplicator<TKey, TValue> : IDictionary<TKey, TVal
         /// </summary>
         event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnRemoteRemove;
 
+        /// <summary>
+        /// Called when a [<typeparamref name="TKey"/>, <typeparamref name="TValue"/>] is added on this <see cref="IKNetCompactedReplicator{TKey, TValue}"/>
+        /// </summary>
+        event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnLocalAdd;
+
         /// <summary>
         /// Called when a [<typeparamref name="TKey"/>, <typeparamref name="TValue"/>] is updated on this <see cref="IKNetCompactedReplicator{TKey, TValue}"/>
         /// </summary>
@@ -515,12 +525,18 @@ public override void OnPartitionsLost(Java.Util.Collection<Org.Apache.Kafka.Comm
 
         #region Events
 
+        /// <inheritdoc cref="IKNetCompactedReplicator{TKey, TValue}.OnRemoteAdd"/>
+        public event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnRemoteAdd;
+
         /// <inheritdoc cref="IKNetCompactedReplicator{TKey, TValue}.OnRemoteUpdate"/>
         public event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnRemoteUpdate;
 
         /// <inheritdoc cref="IKNetCompactedReplicator{TKey, TValue}.OnRemoteRemove"/>
         public event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnRemoteRemove;
 
+        /// <inheritdoc cref="IKNetCompactedReplicator{TKey, TValue}.OnLocalAdd"/>
+        public event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnLocalAdd;
+
         /// <inheritdoc cref="IKNetCompactedReplicator{TKey, TValue}.OnLocalUpdate"/>
         public event Action<IKNetCompactedReplicator<TKey, TValue>, KeyValuePair<TKey, TValue>> OnLocalUpdate;
 
@@ -647,9 +663,11 @@ private void OnMessage(KNetConsumerRecord<TKey, TValue> record)
             }
             else
             {
+                bool containsKey = true;
                 ILocalDataStorage data;
                 if (!_dictionary.TryGetValue(record.Key, out data))
                 {
+                    containsKey = false;
                     data = new LocalDataStorage();
                     _dictionary[record.Key] = data;
                 }
@@ -669,7 +687,14 @@ private void OnMessage(KNetConsumerRecord<TKey, TValue> record)
                         data.Value = record.Value;
                     }
                 }
-                OnRemoteUpdate?.Invoke(this, new KeyValuePair<TKey, TValue>(record.Key, record.Value));
+                if (containsKey)
+                {
+                    OnRemoteUpdate?.Invoke(this, new KeyValuePair<TKey, TValue>(record.Key, record.Value));
+                }
+                else
+                {
+                    OnRemoteAdd?.Invoke(this, new KeyValuePair<TKey, TValue>(record.Key, record.Value));
+                }
             }
 
             if (_OnConsumeSyncWaiter != null)
@@ -777,9 +802,11 @@ private void AddOrUpdate(TKey key, TValue value)
                 }
                 else
                 {
+                    bool containsKey = true;
                     ILocalDataStorage data;
                     if (!_dictionary.TryGetValue(key, out data))
                     {
+                        containsKey = false;
                         data = new LocalDataStorage();
                         _dictionary[key] = data;
                     }
@@ -799,7 +826,14 @@ private void AddOrUpdate(TKey key, TValue value)
                             data.Value = value;
                         }
                     }
-                    OnLocalUpdate?.Invoke(this, new KeyValuePair<TKey, TValue>(key, value));
+                    if (containsKey)
+                    {
+                        OnLocalUpdate?.Invoke(this, new KeyValuePair<TKey, TValue>(key, value));
+                    }
+                    else
+                    {
+                        OnLocalAdd?.Invoke(this, new KeyValuePair<TKey, TValue>(key, value));
+                    }
                 }
             }
             else if (UpdateModeOnConsume || UpdateModeOnConsumeSync)