vpruthi/doc-exports
1
0
Fork 0
forked from docs/doc-exports
Code Pull Requests Activity

DMS DEVG 20240715 version

Browse Source 
Reviewed-by: Antonova, Ekaterina <ekantono@noreply.gitea.eco.tsi-dev.otc-service.com>
Co-authored-by: Chen, Junjie <chenjunjie@huawei.com>
Co-committed-by: Chen, Junjie <chenjunjie@huawei.com>
This commit is contained in:
Chen, Junjie 2024-07-16 13:10:42 +00:00 committed by zuul
parent 5bb11b7c7f
commit ce1d5fd717
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
docs/dms/dev/Kafka-java-demo.html
View File

@ -11,8 +11,7 @@
&lt;/dependency&gt;</pre>
</div>
<div class="section" id="Kafka-java-demo__section235013516019"><h4 class="sectiontitle">Preparing Kafka Configuration Files</h4><p id="Kafka-java-demo__p16171537304">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.</p>
<ul id="Kafka-java-demo__ul86714126513"><li id="Kafka-java-demo__li106711612652"><a name="Kafka-java-demo__li106711612652"></a><a name="li106711612652"></a>Producer configuration file (the <strong id="Kafka-java-demo__b335943411212">dms.sdk.producer.properties</strong> file in the <a href="#Kafka-java-demo__li6268103683712">message production code</a>)<p id="Kafka-java-demo__p463910341272">The information in bold is specific to different Kafka instances and must be modified. Other parameters can also be added.</p>
<pre class="screen" id="Kafka-java-demo__screen202453416716">#The topic name is in the specific production and consumption code.
<ul id="Kafka-java-demo__ul86714126513"><li id="Kafka-java-demo__li106711612652"><a name="Kafka-java-demo__li106711612652"></a><a name="li106711612652"></a>Producer configuration file (the <strong id="Kafka-java-demo__b335943411212">dms.sdk.producer.properties</strong> file in the <a href="#Kafka-java-demo__li6268103683712">message production code</a>)<pre class="screen" id="Kafka-java-demo__screen202453416716">#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=<strong id="Kafka-java-demo__b202310349719">ip1:port1,ip2:port2,ip3:port3</strong>
@ -53,7 +52,7 @@ ssl.truststore.password=dms@kafka
ssl.endpoint.identification.algorithm=
# <strong id="Kafka-java-demo__b152805494544">If the security protocol is SASL_PLAINTEXT, the configuration is as follows:</strong>
security.protocol=SASL_PLAINTEXT</pre>
</li><li id="Kafka-java-demo__li156719123520">Consumer configuration file (the <strong id="Kafka-java-demo__b1686581792517">dms.sdk.consumer.properties</strong> file in the <a href="#Kafka-java-demo__li843695925415">message consumption code</a>)<div class="p" id="Kafka-java-demo__p174615571788">The information in bold is specific to different Kafka instances and must be modified. Other parameters can also be added.<pre class="screen" id="Kafka-java-demo__screen15720561581">#The topic name is in the specific production and consumption code.
</li><li id="Kafka-java-demo__li156719123520">Consumer configuration file (the <strong id="Kafka-java-demo__b1686581792517">dms.sdk.consumer.properties</strong> file in the <a href="#Kafka-java-demo__li843695925415">message consumption code</a>)<pre class="screen" id="Kafka-java-demo__screen15720561581">#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=<strong id="Kafka-java-demo__b177118561487">ip1:port1,ip2:port2,ip3:port3</strong>
@ -92,7 +91,6 @@ ssl.truststore.password=dms@kafka
ssl.endpoint.identification.algorithm=
# <strong id="Kafka-java-demo__b596109105515">If the security protocol is SASL_PLAINTEXT, the configuration is as follows:</strong>
security.protocol=SASL_PLAINTEXT</pre>
</div>
</li></ul>
</div>
<div class="section" id="Kafka-java-demo__section5204122943315"><h4 class="sectiontitle">Producing Messages</h4><ul id="Kafka-java-demo__ul426711369375"><li id="Kafka-java-demo__li1026893617376">Test code<div class="codecoloring" codetype="Java" id="Kafka-java-demo__screen18699101917393"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal"> 1</span>