IOT rule fails with "KafkaAction failed to send a message to the specified bootstrap servers. Expiring N record(s) for {Kafka-topic}-2:4600 ms has passed since batch creation"

0

I'm using an IoT rule to publish IoT data with Managed Service Kafka (MSK). However, I frequently encounter the following error, causing messages to be missing. It generally works well, but what could be the reasons for occasional issues like this? Also, I would like to know how to resolve it.

{
    "timestamp": "2023-12-04 11:32:17.213",
    "logLevel": "ERROR",
    "traceId": "b54f9de6-c0b5-7233-8925-49e80e7d099f",
    "accountId": "1234",
    "status": "Failure",
    "eventType": "RuleExecution",
    "clientId": "1234",
    "topicName": "$aws/rules/iot_to_kafka/test3/location",
    "ruleName": "iot_to_kafka",
    "ruleAction": "KafkaAction",
    "resources": {
        "Topic": "appmeter.iot.gps",
        "BootstrapServers": "b-1.abc.abc.c2.kafka.ap-northeast-2.amazonaws.com:9096,b-2.abc.abc.c2.kafka.ap-northeast-2.amazonaws.com:9096,b-3.abc.abc.c2.kafka.ap-northeast-2.amazonaws.com:9096"
    },
    "principalId": "1234",
    "details": "KafkaAction failed to send a message to the specified bootstrap servers. Expiring 6 record(s) for test.iot.gps-2:4600 ms has passed since batch creation"
}
Jiyoung
已提問 5 個月前檢視次數 343 次
沒有答案

您尚未登入。 登入 去張貼答案。

一個好的回答可以清楚地回答問題並提供建設性的意見回饋,同時有助於提問者的專業成長。

回答問題指南