GitHub user tianshimoyi edited a comment on the discussion: Does the
Cluster-level failover of pulsar have any requirements on the version of
pulsar? Is version 2.10 or higher required? 2.9.4 Can it be used?
@merlimat I tried to test with pulsar version 2.9.4, client library version
2.10.3, but it didn't work!
producer code
```java
public class PulsarTest {
public static void main(String[] args) {
String primaryUrl = "pulsar://10.0.87.203:6650";
String secondaryUrl = "pulsar://10.0.88.116:6650";
Map<String, Authentication> m = new HashMap<>();
m.put(secondaryUrl,
AuthenticationFactory.token("eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiJhZG1pbiJ9.KbWpsmPprtHtMyOXk-AK2QFErQaGgjVSzCZDHAcT3YzeHfAtNI5iIAR2buCjnjVa1p3GlYz8keA1ScA5FiRPEZtzbauXj1fhaOKTBZypFs5_Nfojp-gx33qnD6PXgv30JYMm7hCkbKO60ZRIDZbSEMnuCs0tR9_ZIbEylGvsG88pfJABHzILPjvoM0xfJ5goJztEWPWTLN2bxZ5i3uKlfW_ZtCPj94q7GiV1m5Jvhjs-g5kz-4y2ODQarJ7Kk06Nq8Hkb-8KVATFtNxM8oX4yVd9aIwRJ4CihKcO-jmzPx7_SAQlU6v6uITrShOV0qCuk6kaf8e1Ema5wzmIfw5sQA"));
ServiceUrlProvider failover = AutoClusterFailover.builder()
.primary(primaryUrl)
.secondary(List.of(secondaryUrl))
.failoverDelay(10, TimeUnit.SECONDS)
.switchBackDelay(30, TimeUnit.SECONDS)
.checkInterval(1000, TimeUnit.MILLISECONDS)
.secondaryAuthentication(m)
.build();
try {
PulsarClient client = PulsarClient.builder()
.serviceUrlProvider(failover)
.authentication(AuthenticationFactory.token("eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiJhZG1pbiJ9.OFwzpQX0S-KUyKC1b-6S0CuXG9hJbu79jYSMoecHadojJtz9JTJTAALHNG2KTxrb_tzKSvUK5ytRaQ9f66LyPORSbxqJHSo1x3n8A0MlFVaSzVOmge0HSzYm53oHC2NtG7Ng-c5M_r1ZJmZ17oOfmFU_5cU3kOWaIidh4f6h3nyL9l9bDmqhE0pZv_Kv0poUyGSnaYwoi1vR--OxrpGzBdr7KgQs7MCjpFF8UiGnGlgwaFvGb16LixPBXKHrHYPwfDuoSQTFmCY3FM_fp5DUMygDP2-Q1NN9ykESArubydT6Abh0Ebp0PraRhzLm8ad7W4Vo837V4RsJuIimGs6Mow"))
.build();
Producer<String> producer = client.newProducer(Schema.STRING)
.topic("public/default/t1")
.create();
long index = 0;
while (true) {
String msg = new String("hello-" + index);
producer.send(msg);
Thread.sleep(1000);
index = index + 1;
System.out.println(msg + " send ok");
}
} catch (Exception e) {
System.out.println("exit");
e.printStackTrace();
}
}
}
```
Then I shut down all the Broker nodes of the main cluster, and no switchover
occurred. Is there something wrong with the code? Or Broker requires special
configuration ？
GitHub link:
https://github.com/apache/pulsar/discussions/19818#discussioncomment-5328314
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
