Install Java: sudo yum install java-1.8.0

Get Kafka:wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz

Extract Kafka: tar -xzf kafka_2.12-2.2.1.tgz

Get Cluster ARN: aws kafka describe-cluster --cluster-arn "ClusterArn" --region

Create Topic: bin/kafka-topics.sh --create --zookeeper "ZookeeperConnectString" --replication-factor 2 --partitions 1 --topic AWSKafkaTutorialTopic

User the Trust store: cp /usr/lib/jvm/JDKFolder/jre/lib/security/cacerts /tmp/kafka.client.truststore.jks

client.properties: security.protocol=SSL ssl.truststore.location=/tmp/kafka.client.truststore.jks

Get Brokers: aws kafka get-bootstrap-brokers --cluster-arn ClusterArn --region

Producer: ./kafka-console-producer.sh --broker-list BootstrapBrokerStringTls --producer.config client.properties --topic AWSKafkaTutorialTopic

Consumer: ./kafka-console-consumer.sh --bootstrap-server BootstrapBrokerStringTls --consumer.config client.properties --topic AWSKafkaTutorialTopic --from-beginning