게시된 날짜: Jun 21, 2023
AWS Lambda는 이제 Amazon Managed Streaming for Apache Kafka(MSK) 또는 자체 관리형 Kafka를 이벤트 소스로 사용할 때 특정 타임스탬프부터 시작할 수 있도록 지원합니다. 이전에는 Kafka 이벤트 소스 매핑에 trim horizon 또는 latest만 시작 위치로 지정할 수 있었습니다. 이제 타임스탬프부터 시작을 통해 정확한 시점에 메시지 처리를 시작할 수 있습니다. 이는 재해 복구와 같이 이전에 중단한 부분부터 신속하게 처리를 시작하기 위해 새로운 소비자가 필요한 상황에 유용합니다.
특정 타임스탬프부터 시작하도록 Kafka 이벤트 소스 매핑이 구성된 경우 이벤트 소스 매핑은 지정된 타임스탬프에 토픽의 메시지 처리를 시작하거나 지정된 타임스탬프 이후의 첫 번째 메시지를 처리하기 시작합니다. 이 기능을 사용하려면 새 Kafka 이벤트 소스 매핑을 생성하고, StartingPosition를 AT_TIMESTAMP로 설정하고, StartingPositionTimestamp를 원하는 시작 위치로 설정합니다. StartingPositionTimestamp는 Unix 시간 초로 형식으로 지정해야 합니다. Kafka에서 시작 위치는 새로운 소비자 그룹에 대해서만 사용되거나 기존 소비자 그룹이 잘못된(만료된) 오프셋을 가리킬 때에만 사용됩니다. 새 Kafka 이벤트 소스 매핑은 특정 소비자 그룹 ID로 달리 구성되지 않은 경우 새 소비자 그룹 ID를 생성합니다.
이 기능을 사용하는 데 따른 추가 비용은 없습니다. Kafka에 연결된 이벤트 소스 매핑에 의해 트리거된 Lambda 간접 호출에 대한 비용만 지불하면 됩니다. 자세한 내용은 Amazon MSK 및 Apache Kafka에 대한 Lambda 개발자 안내서를 참조하세요.