README.md

Confluent for Kubernetes on EKS

Deploy/undeploy Confluent for Kubernetes on Amazon Elastic Kubernetes Service

Requirements

• AWS CLI
• kubectl
• eksctl
• AWS profile

Scenario 1: Kubernetes cluster admin and the CFK user are the same person

Deploy EKS Cluster and Confluent Platform

./createCfKonEKS.sh basic

Undeploy EKS Cluster and Confluent Platform

./deleteCfKonEKS.sh basic

Scenario 2: Kubernetes cluster admin and the CFK user are different person

Deploy EKS Cluster and Confluent Platform (advanced)

Requirement:

• A domain already registered (sample: example.com)

./createCfKonEKS.sh advanced

Using "kubectl get svc", Add manually these DNS definitions:

DNS name	External IP	Sample
b0.example.com	kafka-0-lb	(xxx.elb.amazonaws.com)
b1.example.com	kafka-1-lb	(yyy.elb.amazonaws.com)
b2.example.com	kafka-2-lb	(zzz.elb.amazonaws.com)
kafka.example.com	kafka-bootstrap-lb	(xyz.elb.amazonaws.com)
controlcenter.example.com	controlcenter-bootstrap-lb	(zyx.elb.amazonaws.com)

Test Producer and Consumer

kafka-console-producer --topic test --bootstrap-server kafka.alexsalvo1.com:9092 --property parse.key=true --property key.separator=,

kafka-console-consumer --bootstrap-server kafka.alexsalvo1.com:9092 --topic test --from-beginning

Undeploy EKS Cluster and Confluent Platform (advanced)

./deleteCfKonEKS.sh advanced

Scenario 3: Kubernetes cluster admin and the CFK user are different person and External SSL

Deploy EKS Cluster and Confluent Platform (external_ssl)

Requirement:

• A domain already registred (sample: example.com)
• Available custom keystore and truststore. Follow this url: https://docs.confluent.io/3.0.0/kafka/ssl.html
  • move on sslcerts/custom folder
  • move on sslcerts/autogenerated folder

./createCfKonEKS.sh external_ssl <password>

Using "kubectl get svc", Add manually these DNS definitions:

DNS name	External IP	Sample
b0.example.com	kafka-0-lb	(xxx.elb.amazonaws.com)
b1.example.com	kafka-1-lb	(yyy.elb.amazonaws.com)
b2.example.com	kafka-2-lb	(zzz.elb.amazonaws.com)
kafka.example.com	kafka-bootstrap-lb	(xyz.elb.amazonaws.com)
controlcenter.example.com	controlcenter-bootstrap-lb	(zyx.elb.amazonaws.com)

Test Producer and Consumer

Create the client-ssl.properties following this sample:

security.protocol=SSL
ssl.truststore.location=sslcerts/client/truststore.jks
ssl.truststore.password=<password>

kafka-console-producer --topic test --bootstrap-server kafka.alexsalvo1.com:9092 --property parse.key=true --property key.separator=, --producer.config client-ssl.properties

kafka-console-consumer --bootstrap-server kafka.alexsalvo1.com:9092 --topic test --consumer.config client-ssl.properties --from-beginning

Undeploy EKS Cluster and Confluent Platform (external_ssl)

./deleteCfKonEKS.sh external_ssl

Scenario 4: Kubernetes cluster admin and the CFK user are different person and Internal/External SSL

Deploy EKS Cluster and Confluent Platform (full_ssl)

Requirement:

• A domain already registred (sample: example.com)
• Available custom keystore and truststore. Follow this url: https://docs.confluent.io/3.0.0/kafka/ssl.html
  • move on sslcerts/custom folder
  • move on sslcerts/autogenerated folder

./createCfKonEKS.sh external_ssl <password>

Using "kubectl get svc", Add manually these DNS definitions:

DNS name	External IP	Sample
b0.example.com	kafka-0-lb	(xxx.elb.amazonaws.com)
b1.example.com	kafka-1-lb	(yyy.elb.amazonaws.com)
b2.example.com	kafka-2-lb	(zzz.elb.amazonaws.com)
kafka.example.com	kafka-bootstrap-lb	(xyz.elb.amazonaws.com)
controlcenter.example.com	controlcenter-bootstrap-lb	(zyx.elb.amazonaws.com)

Test Producer and Consumer

Create the client-ssl.properties following this sample:

security.protocol=SSL
ssl.truststore.location=sslcerts/client/truststore.jks
ssl.truststore.password=<password>

kafka-console-producer --topic test --bootstrap-server kafka.alexsalvo1.com:9092 --property parse.key=true --property key.separator=, --producer.config client-ssl.properties

kafka-console-consumer --bootstrap-server kafka.alexsalvo1.com:9092 --topic test --consumer.config client-ssl.properties --from-beginning

Undeploy EKS Cluster and Confluent Platform (full_ssl)

./deleteCfKonEKS.sh full_ssl