From ce1d5fd7171ea67b35fe51da81f8ff1c9a440d32 Mon Sep 17 00:00:00 2001 From: "Chen, Junjie" Date: Tue, 16 Jul 2024 13:10:42 +0000 Subject: [PATCH] DMS DEVG 20240715 version Reviewed-by: Antonova, Ekaterina Co-authored-by: Chen, Junjie Co-committed-by: Chen, Junjie --- docs/dms/dev/Kafka-java-demo.html | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/docs/dms/dev/Kafka-java-demo.html b/docs/dms/dev/Kafka-java-demo.html index b6816e78..04bb64c7 100644 --- a/docs/dms/dev/Kafka-java-demo.html +++ b/docs/dms/dev/Kafka-java-demo.html @@ -11,8 +11,7 @@ </dependency>

Preparing Kafka Configuration Files

The following describes example producer and consumer configuration files. If ciphertext access is not enabled for the Kafka instance, comment out lines regarding the encryption. Otherwise, set configurations for encrypted access.

-
  • Producer configuration file (the dms.sdk.producer.properties file in the message production code)

    The information in bold is specific to different Kafka instances and must be modified. Other parameters can also be added.

    -
    #The topic name is in the specific production and consumption code.
+
    • Producer configuration file (the dms.sdk.producer.properties file in the message production code)
      #The topic name is in the specific production and consumption code.
 #######################
 #Information about Kafka brokers. ip:port are the connection addresses and ports used by the instance. The values can be obtained by referring to the "Collecting Connection Information" section. Example: bootstrap.servers=100.xxx.xxx.87:909x,100.xxx.xxx.69:909x,100.xxx.xxx.155:909x
 bootstrap.servers=ip1:port1,ip2:port2,ip3:port3
@@ -53,7 +52,7 @@ ssl.truststore.password=dms@kafka
 ssl.endpoint.identification.algorithm=
 # If the security protocol is SASL_PLAINTEXT, the configuration is as follows:
 security.protocol=SASL_PLAINTEXT
      
-
    • Consumer configuration file (the dms.sdk.consumer.properties file in the message consumption code)
      The information in bold is specific to different Kafka instances and must be modified. Other parameters can also be added.
      #The topic name is in the specific production and consumption code.
+
    • Consumer configuration file (the dms.sdk.consumer.properties file in the message consumption code)
      #The topic name is in the specific production and consumption code.
 #######################
 #Information about Kafka brokers. ip:port are the connection addresses and ports used by the instance. The values can be obtained by referring to the "Collecting Connection Information" section. Example: bootstrap.servers=100.xxx.xxx.87:909x,100.xxx.xxx.69:909x,100.xxx.xxx.155:909x
 bootstrap.servers=ip1:port1,ip2:port2,ip3:port3
@@ -92,7 +91,6 @@ ssl.truststore.password=dms@kafka
 ssl.endpoint.identification.algorithm=
 # If the security protocol is SASL_PLAINTEXT, the configuration is as follows:
 security.protocol=SASL_PLAINTEXT
      
-

Producing Messages

  • Test code
     1