Skip to content

Commit

Permalink
Removed TODO comment for issue awslabs#294 as its already working as …
Browse files Browse the repository at this point in the history
…expected
  • Loading branch information
Subham Rakshit committed Jul 9, 2024
1 parent 837fc97 commit d68448a
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -84,10 +84,7 @@ public byte[] fromConnectData(String topic, org.apache.kafka.connect.data.Schema
try {
byte[] deserializedBytes = deserializer.getData(bytes);
SchemaV2 deserializedSchema = deserializer.getSchemaV2(bytes);

//The registry is decided by the configuration in the target region , schema name is the same as the source region
// TODO: Prefix topic name with source cluster alias
// https://github.com/awslabs/aws-glue-schema-registry/issues/294

return serializer.encodeV2(topic, deserializedSchema, deserializedBytes);

} catch(GlueSchemaRegistryIncompatibleDataException ex) {
Expand Down

0 comments on commit d68448a

Please sign in to comment.