package Ġde . br ing me ister . spring . aws . k inesis Ċ Ċ import Ġcom . amazonaws . services . k inesis . model . Put Records Request Ċ import Ġcom . amazonaws . services . k inesis . model . Put Records Request Entry Ċ import Ġcom . fasterxml . jackson . databind . ObjectMapper Ċ import Ġjava . nio . ByteBuffer Ċ Ċ class ĠRequest Factory ( private Ġval ĠobjectMapper : ĠObjectMapper ) Ġ{ ĊĊĠĠĠ Ġfun Ġrequest ( stream Name : ĠString , Ġvar arg Ġpayload : ĠRecord < *, Ġ* >): ĠPut Records Request Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠPut Records Request () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. with Stream Name ( stream Name ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. with Records ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġpayload . map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠPut Records Request Entry () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. with Data ( ByteBuffer . wrap ( object Mapper . writeValue As Bytes ( it ))) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. with Partition Key ( it . partition Key ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ } Ċ