adding ssl

jeffrey-keene · jeffrey-keene · commit a24dff9af0a4 · 2021-10-15T13:31:50.000-06:00
diff --git a/aws_example.py b/aws_example.py
@@ -26,6 +26,7 @@ def run(self):
                                  sasl_aws_msk_iam_access_key_id=AWS_ACCESS_KEY_ID,
                                  sasl_aws_msk_iam_secret_access_key=AWS_SECRET_ACCESS_KEY,
                                  sasl_aws_msk_region=AWS_REGION,
+                                 security_protocol="SSL"
                                  )
 
         while not self.stop_event.is_set():
@@ -51,6 +52,7 @@ def run(self):
                                  sasl_aws_msk_iam_access_key_id=AWS_ACCESS_KEY_ID,
                                  sasl_aws_msk_iam_secret_access_key=AWS_SECRET_ACCESS_KEY,
                                  sasl_aws_msk_region=AWS_REGION,
+                                 security_protocol="SSL"
                                  )
         consumer.subscribe([TOPIC_NAME])
 
@@ -70,6 +72,7 @@ def main():
                                  sasl_aws_msk_iam_access_key_id=AWS_ACCESS_KEY_ID,
                                  sasl_aws_msk_iam_secret_access_key=AWS_SECRET_ACCESS_KEY,
                                  sasl_aws_msk_region=AWS_REGION,
+                                 security_protocol="SSL"
                                  )
 
         topic = NewTopic(name=TOPIC_NAME,

Original file line number	Diff line number	Diff line change
`@@ -26,6 +26,7 @@ def run(self):`
`26`	`26`	`sasl_aws_msk_iam_access_key_id=AWS_ACCESS_KEY_ID,`
`27`	`27`	`sasl_aws_msk_iam_secret_access_key=AWS_SECRET_ACCESS_KEY,`
`28`	`28`	`sasl_aws_msk_region=AWS_REGION,`
	`29`	`+ security_protocol="SSL"`
`29`	`30`	`)`
`30`	`31`
`31`	`32`	`while not self.stop_event.is_set():`
`@@ -51,6 +52,7 @@ def run(self):`
`51`	`52`	`sasl_aws_msk_iam_access_key_id=AWS_ACCESS_KEY_ID,`
`52`	`53`	`sasl_aws_msk_iam_secret_access_key=AWS_SECRET_ACCESS_KEY,`
`53`	`54`	`sasl_aws_msk_region=AWS_REGION,`
	`55`	`+ security_protocol="SSL"`
`54`	`56`	`)`
`55`	`57`	`consumer.subscribe([TOPIC_NAME])`
`56`	`58`
`@@ -70,6 +72,7 @@ def main():`
`70`	`72`	`sasl_aws_msk_iam_access_key_id=AWS_ACCESS_KEY_ID,`
`71`	`73`	`sasl_aws_msk_iam_secret_access_key=AWS_SECRET_ACCESS_KEY,`
`72`	`74`	`sasl_aws_msk_region=AWS_REGION,`
	`75`	`+ security_protocol="SSL"`
`73`	`76`	`)`
`74`	`77`
`75`	`78`	`topic = NewTopic(name=TOPIC_NAME,`