Skip to main content

🧠 AWS MSK Cluster Kafka version is outside support - prod.logic.yaml🟒

Uses​

Test Results πŸŸ’β€‹

Generated at: 2026-10-30T18:09:48.679969159Z Open

ResultIdCondition IndexCondition TextRuntime Error
🟒1.1.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.2.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.6.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.8.2.tiered-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.4.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.5.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.6.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.7.x-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.7.x.kraft-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.8.2-tiered-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.4.1.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.3.2-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.8.x-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.8.x.kraft-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.9.x-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.9.x.kraft-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.0.x-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.0.x.kraft-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.1.x-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.1.x.kraft-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.2.x-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.2.x.kraft-supportedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒2.8.2-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.7.1-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.9.0-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.9.x.custom-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒3.8.x.tiered-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒4.3.x-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒garbage-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒KTVPDKIKX0DER-not-listedβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒empty-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒missing-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒whitespace-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒deployment-type-not-inferred-from-missing-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒revision-token-ignoredβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒deleted-missing-versionβœ”οΈ 199βœ”οΈ setOfText(['DELETING', 'CREATING', 'FAILED']).contains(extract('CA10__state__c'))βœ”οΈ null
🟒CREATING-not-listed-stateβœ”οΈ 199βœ”οΈ setOfText(['DELETING', 'CREATING', 'FAILED']).contains(extract('CA10__state__c'))βœ”οΈ null
🟒FAILED-not-listed-stateβœ”οΈ 199βœ”οΈ setOfText(['DELETING', 'CREATING', 'FAILED']).contains(extract('CA10__state__c'))βœ”οΈ null
🟒FUTURE_STATE-not-listed-stateβœ”οΈ 299βœ”οΈ not(setOfText(['ACTIVE', 'UPDATING', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER']).contains(extract('CA10__state__c')))βœ”οΈ null
🟒UPDATING-expired-current-versionβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒HEALING-expired-current-versionβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒MAINTENANCE-expired-current-versionβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒REBOOTING_BROKER-expired-current-versionβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒missing-stateβœ”οΈ 101βœ”οΈ CA10__state__c.isEmpty()βœ”οΈ null
🟒disappearedβœ”οΈ 99βœ”οΈ isDisappeared(CA10__disappearanceTime__c)βœ”οΈ null
🟒2.1.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.3.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.4.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.5.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.6.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.6.2-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.6.3-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.7.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.7.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.7.2-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.8.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒2.8.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.1.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.2.0-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒3.3.1-current-expiredβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒UPDATING-supported-current-versionβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒UPDATING-missing-current-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒HEALING-supported-current-versionβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒HEALING-missing-current-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒MAINTENANCE-supported-current-versionβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒MAINTENANCE-missing-current-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒REBOOTING_BROKER-supported-current-versionβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒REBOOTING_BROKER-missing-current-versionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒CREATING-missing-version-excludedβœ”οΈ 199βœ”οΈ setOfText(['DELETING', 'CREATING', 'FAILED']).contains(extract('CA10__state__c'))βœ”οΈ null
🟒FAILED-missing-version-excludedβœ”οΈ 199βœ”οΈ setOfText(['DELETING', 'CREATING', 'FAILED']).contains(extract('CA10__state__c'))βœ”οΈ null
🟒DELETING-missing-version-excludedβœ”οΈ 199βœ”οΈ setOfText(['DELETING', 'CREATING', 'FAILED']).contains(extract('CA10__state__c'))βœ”οΈ null
🟒expired-broker-with-supported-looking-revisionβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒supported-broker-with-expired-looking-revisionβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒missing-broker-with-supported-looking-revisionβœ”οΈ 301βœ”οΈ CA10__currentBrokerKafkaVersion__c.isEmpty()βœ”οΈ null
🟒unrecognized-broker-with-supported-looking-revisionβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒supported-broker-without-optional-metadataβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒normalized-expired-version-and-stateβœ”οΈ 399βœ”οΈ setOfText(['1.1.1', '2.1.0', '2.2.1', '2.3.1', '2.4.1', '2.4.1.1', '2.5.1', '2.6.0', '2.6.1', '2.6.2', '2.6.3', '2.7.0', '2.7.1', '2.7.2', '2.8.0', '2.8.1', '3.1.1', '3.2.0', '3.3.1', '3.3.2', '2.8.2.tiered', '2.8.2-tiered', '3.4.0', '3.5.1', '3.6.0', '3.7.x', '3.7.x.kraft']).contains(extract('CA10__currentBrokerKafkaVersion__c'))βœ”οΈ null
🟒normalized-supported-version-and-stateβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒whitespace-stateβœ”οΈ 101βœ”οΈ CA10__state__c.isEmpty()βœ”οΈ null
🟒unrecognized-state-before-missing-versionβœ”οΈ 299βœ”οΈ not(setOfText(['ACTIVE', 'UPDATING', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER']).contains(extract('CA10__state__c')))βœ”οΈ null
🟒5.0.x-future-compliantβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒5.0.x.kraft-future-compliantβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null
🟒100.0.x-future-compliantβœ”οΈ 400βœ”οΈ otherwiseβœ”οΈ null

Generation Bundle​

FileMD5
Open/ce/ca/aws/msk/cluster-kafka-version-support/policy.yamlAFD837590FCD989C56E41E1BBB9B5218
Open/ce/ca/aws/msk/cluster-kafka-version-support/prod.logic.yaml14D599C3CFA0519FE42546567DE1CD97
Open/ce/ca/aws/msk/cluster-kafka-version-support/test-data.jsonCD9D6AF2FF2C66121319EBFFF43A3A8F
Open/types/CA10__CaAwsMskCluster__c/object.extracts.yamlC25AA7F4E1C868FFDB78E8D08FFFB933

Available Commands​

repo-manager policies generate FULL /ce/ca/aws/msk/cluster-kafka-version-support/prod.logic.yaml
repo-manager policies generate DEBUG /ce/ca/aws/msk/cluster-kafka-version-support/prod.logic.yaml
repo-manager policies generate CAPTURE_TEST_DATA /ce/ca/aws/msk/cluster-kafka-version-support/prod.logic.yaml
repo-manager policies generate TESTS /ce/ca/aws/msk/cluster-kafka-version-support/prod.logic.yaml
# Execute tests
repo-manager policies test /ce/ca/aws/msk/cluster-kafka-version-support/prod.logic.yaml

Content​

Open File

---
# AWS MSK calendar verified 2026-10-27.
# https://docs.aws.amazon.com/msk/latest/developerguide/supported-kafka-versions.html
# All listed cutoffs have passed; future cutoffs should use IS_BEFORE_TODAY.
# shortcut: update the expired-version list when additional AWS support cutoffs pass.
inputType: CA10__CaAwsMskCluster__c
importExtracts:
- file: /types/CA10__CaAwsMskCluster__c/object.extracts.yaml
testData:
- file: test-data.json
conditions:
- status: INAPPLICABLE
currentStateMessage: The MSK cluster is creating, failed, or being deleted and is outside the operational lifecycle scope.
check:
CONTAINS:
arg:
SET:
itemType: TEXT
items:
- DELETING
- CREATING
- FAILED
search:
EXTRACT: CA10__state__c
- status: UNDETERMINED
currentStateMessage: The MSK cluster is not in a recognized operational state; verify the current broker version.
check:
NOT:
arg:
CONTAINS:
arg:
SET:
itemType: TEXT
items:
- ACTIVE
- UPDATING
- HEALING
- MAINTENANCE
- REBOOTING_BROKER
search:
EXTRACT: CA10__state__c
- status: INCOMPLIANT
currentStateMessage: The current broker Kafka version is past its published AWS MSK end-of-support date.
remediationMessage: Verify the live version and plan a tested upgrade to a supported compatible Kafka version; AWS can automatically upgrade clusters after end of support.
check:
CONTAINS:
arg:
SET:
itemType: TEXT
items:
- 1.1.1
- 2.1.0
- 2.2.1
- 2.3.1
- 2.4.1
- 2.4.1.1
- 2.5.1
- 2.6.0
- 2.6.1
- 2.6.2
- 2.6.3
- 2.7.0
- 2.7.1
- 2.7.2
- 2.8.0
- 2.8.1
- 3.1.1
- 3.2.0
- 3.3.1
- 3.3.2
- 2.8.2.tiered
- 2.8.2-tiered
- 3.4.0
- 3.5.1
- 3.6.0
- 3.7.x
- 3.7.x.kraft
search:
EXTRACT: CA10__currentBrokerKafkaVersion__c
otherwise:
status: COMPLIANT
currentStateMessage: The cluster uses a Kafka version that has not reached end of support on Amazon MSK.