read_options.py

options_read = {
    "kafka.bootstrap.servers":
        "<your_kafka_brokers>",
    "subscribe":
        "<your_topic_name>",
    "startingOffsets":
        "earliest",
    "endingOffsets":
        "latest",
    "kafka.ssl.truststore.location":
        "/tmp/kafka.client.truststore.jks",
    "kafka.security.protocol":
        "SASL_SSL",
    "kafka.sasl.mechanism":
        "AWS_MSK_IAM",
    "kafka.sasl.jaas.config":
        "software.amazon.msk.auth.iam.IAMLoginModule required;",
    "kafka.sasl.client.callback.handler.class":
        "software.amazon.msk.auth.iam.IAMClientCallbackHandler"
}