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