We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ab4b130 commit c49d5afCopy full SHA for c49d5af
pubsub/pulsar/pulsar_test.go
@@ -462,7 +462,7 @@ func TestParsePulsarMetadataReplicateSubscriptionState(t *testing.T) {
462
},
463
{
464
name: "test replicateSubscriptionState false",
465
- replicateSubscriptionState: "false",
+ replicateSubscriptionState: "false",
466
expected: false,
467
468
@@ -478,11 +478,11 @@ func TestParsePulsarMetadataReplicateSubscriptionState(t *testing.T) {
478
m.Properties = map[string]string{
479
"host": "a",
480
}
481
-
+
482
if tc.replicateSubscriptionState != "" {
483
m.Properties["replicateSubscriptionState"] = tc.replicateSubscriptionState
484
485
486
meta, err := parsePulsarMetadata(m)
487
488
require.NoError(t, err)
0 commit comments