Skip to content

[Java] Migrate examples module from AWS SDK v1 Kinesis to v2#505

Open
jvdadda wants to merge 2 commits intoawslabs:masterfrom
mobsuccess-devops:migrate-examples-kinesis-to-v2
Open

[Java] Migrate examples module from AWS SDK v1 Kinesis to v2#505
jvdadda wants to merge 2 commits intoawslabs:masterfrom
mobsuccess-devops:migrate-examples-kinesis-to-v2

Conversation

@jvdadda
Copy link
Copy Markdown

@jvdadda jvdadda commented Mar 9, 2026

Issue #, if available: #500

Description of changes:

Migrate the examples module from AWS SDK v1 Kinesis client to v2:

  • Replace com.amazonaws:aws-java-sdk-kinesis dependency with software.amazon.awssdk:kinesis
  • Rewrite PutRecordGetRecordExample.java to use KinesisClient (v2) instead of AmazonKinesis (v1), using the v2 builder pattern for all request/response objects

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

Copy link
Copy Markdown

Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

Migrates the examples module from AWS SDK for Java v1 Kinesis usage to AWS SDK for Java v2, as part of the broader effort in #500 to remove AWS SDK v1 references.

Changes:

  • Replaced com.amazonaws:aws-java-sdk-kinesis with software.amazon.awssdk:kinesis in the examples module.
  • Rewrote PutRecordGetRecordExample to use KinesisClient (AWS SDK v2) and v2 request/response builders.
  • Removed AWS SDK v1 STS dependencies from serializer-deserializer and multilang-schema-registry, and updated comments/Javadocs referencing v1 credential provider naming.

Reviewed changes

Copilot reviewed 8 out of 8 changed files in this pull request and generated 3 comments.

Show a summary per file
File Description
serializer-deserializer/src/test/java/com/amazonaws/services/schemaregistry/deserializers/avro/AWSKafkaAvroDeserializerTest.java Updates test comment to reflect v2 AwsCredentialsProvider naming.
serializer-deserializer/src/test/java/com/amazonaws/services/schemaregistry/deserializers/GlueSchemaRegistryKafkaDeserializerTest.java Updates test comment to reflect v2 AwsCredentialsProvider naming.
serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/deserializers/avro/AWSKafkaAvroDeserializer.java Updates Javadoc wording for v2 credential provider type.
serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/deserializers/GlueSchemaRegistryKafkaDeserializer.java Updates Javadoc wording for v2 credential provider type.
serializer-deserializer/pom.xml Removes unused AWS SDK v1 STS dependency.
multilang-schema-registry/pom.xml Removes unused AWS SDK v1 STS dependency.
examples/src/main/java/com/amazonaws/services/schemaregistry/examples/kds/PutRecordGetRecordExample.java Migrates Kinesis calls to AWS SDK v2 (KinesisClient, builder-based requests).
examples/pom.xml Switches examples module dependency from SDK v1 Kinesis to SDK v2 Kinesis.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

You can also share your feedback on Copilot code review. Take the survey.

Replace com.amazonaws:aws-java-sdk-kinesis with software.amazon.awssdk:kinesis
and migrate PutRecordGetRecordExample.java from AmazonKinesis (v1) to
KinesisClient (v2) using the builder pattern.
…mple

- Fix describeStream pagination by using exclusiveStartShardId
- Remove dead code (ignored shardId() return value)
- Wrap KinesisClient in try-with-resources to prevent resource leak
@jvdadda jvdadda changed the title Migrate examples module from AWS SDK v1 Kinesis to v2 [Java] Migrate examples module from AWS SDK v1 Kinesis to v2 Mar 9, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants