Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fix
reflect.DeepEqual
both receiving pointers (#5854)
In `processClusterCreateStream` there was a call to `reflect.DeepEqual` with different types making it always fail. `mset.config()` is the config itself, whereas `sa.Config` is a pointer to the config. So we need to pass `mset.config()` as a pointer instead. In `processClusterCreateConsumer` this was done as well: ```go cfg := o.config() if isConfigUpdate = !reflect.DeepEqual(&cfg, ca.Config); isConfigUpdate { ``` <!-- Please make sure to read CONTRIBUTING.md, then delete this notice and replace it with your PR description. The below sign-off certifies that the contribution is your original work and that you license the work to the project under the Apache-2.0 license. We cannot accept contributions without it. --> Signed-off-by: Maurice van Veen <[email protected]>
- Loading branch information