diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java index 2d96e9463..63b0fba71 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java @@ -57,6 +57,9 @@ public static void main(String[] args) throws ClientException { String endpoints = "foobar.com:8080"; ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder() .setEndpoints(endpoints) + // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in + // client configuration to solve the problem please if SSL is not essential. + // .enableSsl(false) .setCredentialProvider(sessionCredentialsProvider) .build(); String consumerGroup = "yourConsumerGroup"; diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java index 76c037ecc..3a57b8f6b 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java @@ -51,6 +51,9 @@ private static Producer buildProducer(TransactionChecker checker, String... topi new StaticSessionCredentialsProvider(ACCESS_KEY, SECRET_KEY); ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder() .setEndpoints(ENDPOINTS) + // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in + // client configuration to solve the problem please if SSL is not essential. + // .enableSsl(false) .setCredentialProvider(sessionCredentialsProvider) .build(); final ProducerBuilder builder = provider.newProducerBuilder() diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java index d5119cebe..008fdc7e2 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java @@ -49,6 +49,9 @@ public static void main(String[] args) throws ClientException, InterruptedExcept String endpoints = "foobar.com:8080"; ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder() .setEndpoints(endpoints) + // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in + // client configuration to solve the problem please if SSL is not essential. + // .enableSsl(false) .setCredentialProvider(sessionCredentialsProvider) .build(); String tag = "yourMessageTagA"; diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java index e349b82a4..d18ddde04 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java @@ -52,6 +52,9 @@ public static void main(String[] args) throws ClientException { String endpoints = "foobar.com:8080"; ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder() .setEndpoints(endpoints) + // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in + // client configuration to solve the problem please if SSL is not essential. + // .enableSsl(false) .setCredentialProvider(sessionCredentialsProvider) .build(); String consumerGroup = "yourConsumerGroup";