Skip to content

AWS Kinesis API Put Records

AWS Kinesis API - Put recordsΒΆ

  • PutRecord API + [[Partition key]] that gets [[hashed]]
  • Key is hashed to determine [[shard id]]
  • The same key goes to the same [[partition]] (helps with ordering for a specific key)
  • Messages sent get a "[[sequence number]]"
  • Choose a partition key that is highly distributed (helps prevent "hot partition")
    • user_id if many users
    • Not country_id if 90% of the users are in one country
  • Use [[batching]] with PutRecords to reduce costs and increase throughput
  • ProvisionedThroughPutExceeded if we go over the limits
  • Can use CLI, AWS SDK, or producer libraries from various frameworks