AWS DynamoStream에서 API를 AWS KCL을 기반으로 작업하고 있습니다. 처리하지 못한 레코드를받은 경우 해당 레코드를 나중에 다시 사용할 수있게하려고합니다. 예를 들어 나는 원격 DB에 저장하려고하는데 언젠가는 네트워크 문제를 경험합니다. 내 질문은 : 내가 나타 내기 위해 어떤 방법으로 체크 포인터를 사용할 수 I 레코드가 처리되지나요?
현재 Golang 버전에 간단한 Kinesis 클라이언트 라이브러리 (KCL)를 작성 중입니다. 내 간단한 KCL을 위해 원하는 기능 중 하나는 여러 레코드 프로세서와 EC2 인스턴스에 분산 된 샤드를로드하는 것입니다. 예를 들어 별도의 EC2 인스턴스에서 실행되는 두 개의 레코드 프로세서와 네 개의 키네시스 조각이 있습니다. 로드 균형 조정 기능을 사용하
나는 KCL을 기반으로 nodejs로 응용 프로그램을 만들고 있습니다. processRecords 함수에서 kinesis에서 얻은 레코드를 http 요청과 함께 웹 서비스로 보내려고했습니다. 그러나 웹 서비스를 사용할 수 없으면 http 요청이 실패합니다. Kinesis에서 기록을 가져와 pagerduty에 경고를 보내려면 KCL을 중지하고 싶습니다. 누구
: 작업자는 자바 ExecutorService를 작업을 사용하여 기록 프로세서 메소드를 호출합니다. 작업이 실패하면 작업자는 레코드 프로세서에서 처리중인 샤드의 제어를 유지합니다. 작업자가 새 레코드 프로세서 태스크를 시작하여 해당 샤드를 처리합니다. 자세한 내용은 읽기 제한을 참조하십시오. AWS의 문서에 another page에 따르면 는 : 운동성 클
DynamoDB Streams + Kinesis 클라이언트 라이브러리 (KCL)를 사용하고 있습니다. 이벤트가 스트림에서 생성 된 시점과 KCL 측에서 처리 된 시점 간의 대기 시간을 측정하려면 어떻게해야합니까? 아시다시피 KCL의 MillisBehindLatest 메트릭은 Kinesis Stream (DynamoDB 스트림 제외)에만 해당됩니다. appr
IRecordProcessor의 processRecords 메서드가 worker에서 언제 호출되는지 알고 싶습니다. 이전에 processRecords에 대한 이전 호출이 아직 완료되지 않은 경우 작업자가 next processRecords를 호출합니까? 작업자가 kinesis에서 새 레코드를 가져 오기 시작하거나 현재 레코드가 실행을 완료 할 때까지 기다릴