cannot create IOT rule action to MSK cluster

Question

When configuring an IOT rule action for MSK, I get the following error.

> 1 validation error detected: Value '[]' at 'topicRulePayload.actions.1.member.kafka.headers' failed to satisfy constraint: Member must have length greater than or equal to 1

I have followed the instruction for configuration from these guides. I can successfully produce and consume MSK messages via Cloud9 IDE.

[Field Notes: Deliver Messages Using an IoT Rule Action to Amazon Managed Streaming for Apache Kafka](https://aws.amazon.com/blogs/architecture/field-notes-deliver-messages-using-an-iot-rule-action-to-amazon-managed-streaming-for-apache-kafka/)

[How to integrate AWS IoT Core with Amazon MSK](https://aws.amazon.com/blogs/iot/how-to-integrate-aws-iot-core-with-amazon-msk/)

I do not understand how this error relates to the configuration. There is no option to configure headers in the rule action UI.

Answer

I ran into the same issue today, seems like a bug with the AWS Console because I was able to create the rule through the CLI.

Here is the command:
```
aws iot create-topic-rule --rule-name  --topic-rule-payload file://iot.json
```
and the input file:
```
{
    "sql": "",
    "description": "",
    "actions": [
        {
            "kafka": {
                "destinationArn": "arn:aws:iot:******************",
                "topic": "",
                "clientProperties": {
                    "acks": "1",
                    "bootstrap.servers": "****************************",
                    "compression.type": "none",
                    "key.serializer": "org.apache.kafka.common.serialization.StringSerializer",
                    "sasl.mechanism": "SCRAM-SHA-512",
                    "sasl.scram.password": "************",
                    "sasl.scram.username": "*******************",
                    "security.protocol": "SASL_SSL",
                    "value.serializer": "org.apache.kafka.common.serialization.ByteBufferSerializer"
                }
            }
        }
    ]
}
```

cannot create IOT rule action to MSK cluster

相关内容