core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java [187:196]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                Iterator<Map.Entry<String, Set<byte[]>>> iterator = entries.iterator();
                while (iterator.hasNext()) {
                    Map.Entry<String, Set<byte[]>> next = iterator.next();

                    Set<byte[]> keySet = next.getValue();

                    if (keySet != null) {
                        keySet.removeIf(rocksDBKey -> Arrays.equals(rocksDBKey, key));
                        if (keySet.size() == 0) {
                            iterator.remove();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java [204:213]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                Iterator<Map.Entry<String, Set<byte[]>>> iterator = entries.iterator();
                while (iterator.hasNext()) {
                    Map.Entry<String, Set<byte[]>> next = iterator.next();

                    Set<byte[]> keySet = next.getValue();

                    if (keySet != null) {
                        keySet.removeIf(rocksDBKey -> Arrays.equals(rocksDBKey, key));
                        if (keySet.size() == 0) {
                            iterator.remove();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -