사용자 지정 플러그인 생성 - Amazon Managed Streaming for Apache Kafka

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

사용자 지정 플러그인 생성

플러그인은 커넥터 로직을 정의하는 코드가 포함된 AWS 리소스입니다. S3 버킷에 JAR 파일(또는 하나 이상의 JAR 파일이 포함된 ZIP 파일)을 업로드하고 플러그인을 생성할 때 버킷의 위치를 지정합니다. 플러그인이 생성되면 MSK Connect는 해당 시점에 S3 객체의 콘텐츠를 복사합니다. S3 객체에 대한 링크는 유지 관리하지 않으므로 객체에 대한 후속 수정 사항은 플러그인 또는 해당 커넥터에 영향을 주지 않습니다. 커넥터를 생성할 때 MSK Connect에서 사용할 플러그인을 지정합니다. 플러그인과 커넥터의 관계는 one-to-many입니다. 동일한 플러그인에서 하나 이상의 커넥터를 생성할 수 있습니다.

참고

사용자 지정 플러그인은 업데이트할 수 없습니다. 플러그인 코드의 새 버전을 사용하려면 플러그인을 참조하는 모든 커넥터를 삭제하고 플러그인을 삭제한 다음 다시 생성합니다.

사용자 지정 플러그인의 종속성 패키징

플러그인에 필요한 모든 JAR 파일과 종속성을 포함하는 것이 좋습니다. 커넥터를 다음 중 하나로 패키징합니다.

  • 플러그인에 필요한 모든 JAR 파일과 종속성을 포함하는 ZIP 파일입니다.

  • 플러그인 및 해당 종속성에 대한 모든 클래스 파일을 포함하는 단일 uber JAR입니다.

플러그인 종속성을 번들링하지 않으면 런타임 환경의 가용성 또는 호환성에 영향을 미치고 예기치 않은 오류가 발생할 수 있습니다.

커넥터를 위한 코드를 개발하는 방법에 대한 자세한 내용은 Apache Kafka 설명서의 커넥터 개발 안내서를 참조하세요.

를 사용하여 사용자 지정 플러그인 생성 AWS Management Console

  1. https://console.aws.amazon.com/msk/에서 Amazon MSK 콘솔을 엽니다.

  2. 왼쪽 창의 MSK Connect에서 사용자 지정 플러그인을 선택합니다.

  3. 사용자 지정 플러그인 생성을 선택합니다.

  4. S3 찾아보기(Browse S3)를 선택합니다.

  5. S3 버킷 목록에서 플러그인을 위한 JAR 또는 ZIP 파일이 있는 버킷을 선택합니다.

  6. 개체 목록에서 플러그인의 JAR 또는 ZIP 파일 왼쪽에 있는 상자를 선택한 다음 선택을 선택합니다.

  7. 사용자 지정 플러그인 생성을 선택합니다.

MSK Connect API를 사용하여 사용자 지정 플러그인을 생성하려면 CreateCustomPlugin을 참조하세요.