π‘οΈ AWS MSK Cluster Client-Broker Encryption is not enabledπ’
- Contextual name: π‘οΈ Cluster Client-Broker Encryption is not enabledπ’
- ID:
/ce/ca/aws/msk/cluster-client-broker-encryption - Tags:
- π’ Policy with categories
- π’ Policy with type
- π’ Production policy
- Policy Type:
COMPLIANCE_POLICY - Policy Categories:
SECURITY
Logicβ
- π§ prod.logic.yamlπ’
- π AWS MSK Cluster
- π AWS MSK Cluster - object.extracts.yaml
- π§ͺ test-data.json
Similar Policiesβ
- AWS Security Hub: [MSK.1] MSK clusters should be encrypted in transit among broker nodes
Descriptionβ
Descriptionβ
This policy identifies AWS Managed Streaming for Apache Kafka (MSK) Clusters that are not configured to enforce TLS encryption for data in transit between clients and brokers.
Rationaleβ
Encryption in transit protects data from unauthorized access, including eavesdropping and man-in-the-middle attacks. Enforcing TLS for client-to-broker communication ensures that sensitive Kafka data remains secure while traversing the network.
Auditβ
This policy flags an AWS MSK Cluster as
INCOMPLIANTwhen the Encryption: Client Broker field is set as PLAINTEXT or TLS_PLAINTEXT.
Remediationβ
Remediationβ
Enforce TLS Encryption for ClientβBroker Communicationβ
Update the MSK cluster security configuration to require TLS encryption for all data in transit between Kafka clients and brokers.
Ensure that all Kafka producers and consumers are configured to use TLS before applying this change. Clients that do not support TLS will lose connectivity once the update is completed.
From Command Lineβ
Step 1: Retrieve the Current Cluster Versionβ
Run the following command to obtain the clusterβs current version, which is required to perform an update:
aws kafka describe-cluster \
--cluster-arn {{cluster-arn}} \
--query 'ClusterInfo.CurrentVersion' \
--output textStep 2: Update the Cluster Security Configurationβ
Execute the following command to enforce TLS encryption for client-to-broker communication. Replace authentication-related values with those appropriate for your environment.
aws kafka update-security \
--cluster-arn {{cluster-arn}} \
--current-version {{current-version}} \
--encryption-info '{
... [see more](remediation.md)