Claim Check pattern for Confluent Kafka

I am looking for guidance for implementing a claim check pattern for our Confluent Kafka integration with Amazon S3 as a datastore. Do we have example implementations around Java that I could refer / get help with? Thank you.