Sink Connecntor 생성 도와주세요 ... ㅠㅠ

Question

문제 상황을 정리한 Notion입니다.https://eminent-pruner-9ad.notion.site/Sink-Connector-Schema-Parquet-4f556e072a644e9c84b1f78d26faddae?pvs&#61;4MSK에서 S3 싱크 커넥터 생성 시 Parquet 파일 저장을 목표로 하고 있습니다. connector.class&#61;io.confluent.connect.s3.S3SinkConnector format.class&#61;io.confluent.connect.s3.format.parquet.ParquetFormat partitioner.class&#61;io.confluent.connect.storage.partitioner.DefaultPartitioner storage.class&#61;io.confluent.connect.s3.storage.S3Storage s3.region&#61;us-east-2 flush.size&#61;2 tasks.max&#61;1 topics&#61;kwontest s3.bucket.name&#61;kwonsink key.converter.region&#61;us-east-2 value.converter.region&#61;us-east-2 key.converter.avroRecordType&#61;GENERIC_RECORD value.converter.avroRecordType&#61;GENERIC_RECORD key.converter.compatibility&#61;BACKWARD value.converter.compatibility&#61;BACKWARD key.converter.schemaAutoRegistrationEnabled&#61;true value.converter.schemaAutoRegistrationEnabled&#61;true store.kafka.headers&#61;false schema.compatibility&#61;NONE key.converter&#61;com.amazonaws.services.schemareregistry.kafkakconnect.AWSKafkaAvroConverter value.converter&#61;com.amazonaws.services.schemareregistry.kafkakconnect.AWSKafkaAvroConverter store.kafka.keys&#61;false아래와 같은 문제가 발생합니다.Key & value converter 값인 com.amazonaws.services.schemareregistry.kafkakconnect.AWSKafkaAvroConverter 인식 문제로 판단되는데, 어떻게 문제 해결할 수 있는지 조언 주시면 진심으로 감사드리겠습니다.

カワウソ · Answer

https://github.com/awslabs/aws-glue-schema-registry/blob/master/avro-kafkaconnect-converter/src/main/java/com/amazonaws/services/schemaregistry/kafkaconnect/AWSKafkaAvroConverter.javacom.amazonaws.services.schemareregistry.kafkakconnect.AWSKafkaAvroConverter

Sink Connecntor 생성 도와주세요 ... ㅠㅠ

1개의 답변

#connection 목록