Topic

Create

kafka-topics.sh \
--bootstrap-server $MSK_BOOTSTRAP_ADDRESS \
--command-config /tmp/client_iam.properties \
--create --topic workshop-test \
--partitions 5  \
--replication-factor 3

List

kafka-topics.sh \
--bootstrap-server $MSK_BOOTSTRAP_ADDRESS \
--command-config /tmp/client_iam.properties \
--list

Describe

kafka-topics.sh \
--bootstrap-server $MSK_BOOTSTRAP_ADDRESS \
--command-config /tmp/client_iam.properties \
--describe --topic workshop-test

Producer Test

kafka-console-producer.sh \
--bootstrap-server $MSK_BOOTSTRAP_ADDRESS \
--producer.config /tmp/client_iam.properties \
--topic workshop-test

Consumer Test

kafka-console-consumer.sh \
--bootstrap-server $MSK_BOOTSTRAP_ADDRESS \
--consumer.config /tmp/client_iam.properties \
--topic workshop-test

Delete

kafka-topics.sh \
--bootstrap-server $MSK_BOOTSTRAP_ADDRESS \
--command-config /tmp/client_iam.properties \
--delete --topic workshop-test