Added Security flag

raphlopez · Jun 8, 2022 · 3d6abff · 3d6abff
1 parent fdd421b
commit 3d6abff
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -35,8 +35,8 @@ Setup
 
 | Parameter Name | Parameter Value                                                                                                              |
 |----------------|------------------------------------------------------------------------------------------------------------------------------|
-|PROJECT_NAME    | Name of the Aiven Project where the Aiven for Apache Kafka service is running                                                       |
-|SERVICE_NAME    | Name of the Aiven for Apache Kafka service running                                                                                  |
+|PROJECT_NAME    | Name of the Aiven Project where the Aiven for Apache Kafka service is running                                                |
+|SERVICE_NAME    | Name of the Aiven for Apache Kafka service running                                                                           |
 |TOPIC           | Name of the Topic to write messages in                                                                                       |
 |PARTITIONS      | Number of partitions to set when creating a topic (this will **NOT** alter existing topics)                                  |
 |REPLICATION     | Number of replicas to set when creating a topic (this will **NOT** alter existing topics)                                    |
@@ -46,6 +46,7 @@ Setup
 |USERNAME        | Aiven account username                                                                                                       |
 |TOKEN           | Aiven account token                                                                                                          |
 |PRIVATELINK     | Flag to say if the service is under a privatelink, to fetch the correct URL                                                  |
+|SECURITY        | Flag to say if the Kafka service is using SSL or not, possible values are ``SSL`` or ``PLAINTEXT``                           |
 
 
 To know more about parameters, check the underline [Apache Kafka Python Fake Data Producer](https://github.com/aiven/python-fake-data-producer-for-apache-kafka) repository.

diff --git a/conf/env.conf.sample b/conf/env.conf.sample
@@ -8,4 +8,5 @@ MAX_TIME=0
 SUBJECT="metric"
 USERNAME="my_aiven_email"
 TOKEN="my_aiven_token"
-PRIVATELINK="NO"
+PRIVATELINK="NO"
+SECURITY="SSL"
diff --git a/run.sh b/run.sh
@@ -40,4 +40,5 @@ python python-fake-data-producer-for-apache-kafka/main.py --cert-folder ./certs/
   --topic-name $TOPIC \
   --nr-messages $NR_MESSAGES \
   --max-waiting-time $MAX_TIME \
-  --subject $SUBJECT
+  --subject $SUBJECT	\
+  --security-protocol $SECURITY