MSK Connect Debezium Connector using AWS Glue Schema Registry for AVRO serialization

0

We are trying to integrate change data capture into our MSK cluster using the Debezium SQL Server plugin with AVRO serialization and AWS Glue Schema Registry. The connector appears to be working correctly as we can see the messages flowing into the Kafka topic and the AVRO schema is registered into our schema registry. However, when we attempt to deserialize the message from Kafka in a lambda function (MSK trigger), we are getting an error saying that the Schema cannot be found. We are using this library to do the AVRO serializaton/deserialization in both the connector and our lambda function. We've added some additional logging to the library and have found that the schema version id that gets written into the message during serialization is different than the one that gets pulled out of the message during deserialization. Has anyone successfully used Debezium with MSK connect and AWS Glue Schema registry? Pertinent configuration for our MSK connector is provided below:

  "key.converter": "org.apache.kafka.connect.storage.StringConverter",
  "key.converter.schemas.enable": "false",
  "key.converter.avroRecordType": "GENERIC_RECORD",
  "key.converter.region": "AWS_REGION",
  "key.converter.registry.name": "SCHEMA_REGISTRY_NAME",
  "key.converter.schemaAutoRegistrationEnabled": "true",
  "value.converter": "com.amazonaws.services.schemaregistry.kafkaconnect.AWSKafkaAvroConverter",
  "value.converter.schemas.enable": "true",
  "value.converter.avroRecordType": "GENERIC_RECORD",
  "value.converter.region": "AWS_REGION",
  "value.converter.registry.name": "SCHEMA_REGISTRY_NAME",
  "value.converter.schemaAutoRegistrationEnabled": "true",
질문됨 2년 전177회 조회
답변 없음

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠