aws-msk-kafka-record-value-data-plane

Kafka topics contain arbitrary message keys, values, and headers that may carry plaintext credentials.

awscritical service: aws:msk emits CanReadData

Where it sits

locationKafka consumer record key/value/headers
location kindmessage_body
data kindscredential password api_key bearer_token session_token customer_data pii
emits edgeCanReadData
serviceMSK (Kafka) (aws:msk)

Collection recipe

access modedata_plane
operationKafka Fetch/Consume
response pathrecord key/value/headers
encodingprotocol_native
params{"BootstrapBrokers": "\u003cbrokers\u003e", "Topic": "\u003ctopic\u003e"}

Required permissions

kafka-cluster:Connect
kafka-cluster:DescribeTopic
kafka-cluster:ReadData

References

move · open · esc close