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.
-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. +
#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-
#The topic name is in the specific production and 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-
1
|