提交 0884d7cc 编写于 作者: M Matteo Merli 提交者: xiaolong.ran

Set default ensemble size to 2 in service conf, to match broker.conf (#5359)

* Set default ensemble size to 2 in service conf, to match broker.conf

* Fixed test

(cherry picked from commit be5a7cf9)
上级 10a45012
......@@ -777,19 +777,19 @@ public class ServiceConfiguration implements PulsarConfiguration {
category = CATEGORY_STORAGE_ML,
doc = "Number of bookies to use when creating a ledger"
)
private int managedLedgerDefaultEnsembleSize = 1;
private int managedLedgerDefaultEnsembleSize = 2;
@FieldContext(
minValue = 1,
category = CATEGORY_STORAGE_ML,
doc = "Number of copies to store for each message"
)
private int managedLedgerDefaultWriteQuorum = 1;
private int managedLedgerDefaultWriteQuorum = 2;
@FieldContext(
minValue = 1,
category = CATEGORY_STORAGE_ML,
doc = "Number of guaranteed copies (acks to wait before write is complete)"
)
private int managedLedgerDefaultAckQuorum = 1;
private int managedLedgerDefaultAckQuorum = 2;
//
//
......
......@@ -672,7 +672,7 @@ public class AdminApiTest extends MockedPulsarServiceBaseTest {
policies.auth_policies.namespace_auth.remove("my-role");
assertEquals(admin.namespaces().getPolicies("prop-xyz/ns1"), policies);
assertEquals(admin.namespaces().getPersistence("prop-xyz/ns1"), new PersistencePolicies(1, 1, 1, 0.0));
assertEquals(admin.namespaces().getPersistence("prop-xyz/ns1"), new PersistencePolicies(2, 2, 2, 0.0));
admin.namespaces().setPersistence("prop-xyz/ns1", new PersistencePolicies(3, 2, 1, 10.0));
assertEquals(admin.namespaces().getPersistence("prop-xyz/ns1"), new PersistencePolicies(3, 2, 1, 10.0));
......
......@@ -646,7 +646,7 @@ public class V1_AdminApiTest extends MockedPulsarServiceBaseTest {
policies.auth_policies.namespace_auth.remove("my-role");
assertEquals(admin.namespaces().getPolicies("prop-xyz/use/ns1"), policies);
assertEquals(admin.namespaces().getPersistence("prop-xyz/use/ns1"), new PersistencePolicies(1, 1, 1, 0.0));
assertEquals(admin.namespaces().getPersistence("prop-xyz/use/ns1"), new PersistencePolicies(2, 2, 2, 0.0));
admin.namespaces().setPersistence("prop-xyz/use/ns1", new PersistencePolicies(3, 2, 1, 10.0));
assertEquals(admin.namespaces().getPersistence("prop-xyz/use/ns1"), new PersistencePolicies(3, 2, 1, 10.0));
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册