Docs Menu
Docs Home
/
Atlas
/

Atlas Stream Processing 변경 로그

  • AWS S3 비공개 링크 연결 유형에 대한 지원 추가합니다.

  • 연결 레지스트리 UI 에 Test Connection 버튼을 추가하여 각 연결에 대한 연결 테스트를 시작합니다.

  • DataDog로 내보낸 지표를 포함하여 Atlas Stream Processing 지표 에 tenant_name, project_nameorg_name 필드를 추가합니다.

  • 통계를:ref`atlas-sp-agg-cachedlookup` lifetime cache hit/miss 단계의 stats.operatorStats에 추가합니다.

  • Atlas DataDog 통합에서 Stream Processor State 지표에 대한 지원 추가합니다.

  • 스트림 처리 파이프라인에서 JavaScript 실행할 수 있도록 $function 연산자 추가합니다. 자세한 학습 은 $function (스트림 처리)를 참조하세요.

  • $cachedLookup 연산자를 추가하고 $lookup 결과를 특정 TTL에 대해 캐시하여 느리게 변화하는 데이터의 성능을 개선합니다. 자세한 내용은 $cachedLookup를 참조하세요.

  • $emit.config.tombstoneWhen = boolean을 사용하여 Kafka 주제를 압축하기 위해 $emit 단계에서 null 값을 Kafka 주제로 전송하는 기능을 추가합니다. 자세한 내용은 $emit 집계 단계(Stream Processing)를 참조하세요.

  • $source$merge에 대한 Cross Atlas 프로젝트 지원을 추가합니다. 자세한 내용은 Atlas Connection을 참조하세요.

  • Atlas 컬렉션에서 읽을 때 초기 동기화를 지원 위해 $source 에 대한 지원 추가합니다. 자세한 학습 은 MongoDB 컬렉션 변경 스트림을 참조하세요.

  • 컬렉션의 문서를 삭제 수 있도록 $merge 에 대한 지원 추가합니다. 자세한 학습 은 $merge(스트림 처리)를 참조하세요.

  • AWS S3 연결에 대한 지원 추가합니다.

  • Atlas UI 에서 $https 연결 생성 을 지원합니다.

  • $mergeparallelism 필드 추가합니다. 이 필드 쓰기 (write) 작업을 분산할 스레드 수를 지정하여 성능을 향상시킵니다.

  • 출력 메시지 수, DLQ 메시지 수, Kafka 지연 및 변경 스트림 지연과 같은 추가 경고를 생성할 수 있습니다. 자세히 학습하려면 Atlas Stream Processing 경고를 참조하세요.

  • 인수를 받지 않고 스트림 프로세서에서 UUID BSON types 값을 반환하는 createUUID 표현식 지원합니다.

  • eventTime 외에 processingTime 를 지원 하도록 창 연산자에 대한 새로운 구성을 추가합니다. 자세한 학습 은 처리 시간을 참조하세요.

  • 문서 의 모든 스트리밍 메타데이터 포함하는 객체 를 반환하는 $meta 표현식 추가합니다.

  • parseJsonStrings 필드 $https 연산자 에 추가하여 API 호출에서 반환된 JSON 문자열을 구문 분석할 수 있도록 합니다. 자세한 학습 은 $https를 참조하세요.

  • Atlas Stream Processing 스트림 처리 인스턴스를 평가할 때마다 해당 인스턴스의 시스템 시간을 반환하는 $currentDate 표현식 지원합니다.

  • 파일 서명(매직 바이트)이 포함된 JSON 문서 읽기를 지원합니다.

  • interval보다 큰 hopSize 로 Windows 호핑하도록 구성하지 못하는 문제를 수정합니다.

  • Amazon Web Services 에서 Confluent를 사용한 VPC 피어링 지원합니다.

  • Atlas 관리 API를 사용하여 스트림 프로세서를 편집할 수 있도록 지원합니다.

  • Confluent에 대한 AWS Private Link를 지원합니다.

  • EventHubs에 대한 Azure Private Link를 지원합니다.

  • Apache Kafka 시간 초과를 10 초에서 30 초로 늘립니다.

  • 대상 클러스터가 REPAIRING 상태일 때 항상 프로세서를 재시도합니다.

  • 체크포인트 복원 후 partitionIdleTimeout 문제를 수정합니다.

  • 상세 통계에 워터마크 및 창 정보를 더 많이 추가합니다.

  • 생산자 대기열이 가득 차더라도 Apache Kafka 에 대한 메시지 생성 호출이 무기한 중단되지 않도록 합니다.

  • 다중 주제 Apache Kafka 소스 수집을 지원합니다.

  • 소비자 그룹에 대한 Apache Kafka 를 거의 실시간으로 업데이트합니다.offsets

  • Apache Kafka $emit 구성에서 및 compression.type acks 설정을 지원합니다.

  • 컬렉션 없는 $lookup 구문을 지원합니다.

  • Atlas Stream Processing Apache Kafka 오류를 문자열로 직렬화하는 방식을 표준화합니다.

  • $emit$merge 동적 표현식 제한을 1000 로 늘립니다.

  • connectionName 파이프라인 내에서 고유한(으)로 $lookup을 처리합니다.

  • 일시 중지된 클러스터 오류를 개선합니다.

  • $convert를 사용하여 Binary 데이터를 다양한 데이터 유형으로 변환하는 것을 지원합니다. 이를 통해 필요에 따라 Kafka 헤더를 특정 데이터 유형으로 변환할 수 있습니다.

  • Apache Kafka 소스로 사용하는 스트림 프로세서는 sp.processor.stats()에 파티션별 워터마크를 노출합니다.

  • 사용자가 API를 통해 특정 리전에서 스트림 처리 인스턴스를 생성할 수 없었던 버그를 수정합니다.

이 페이지의 내용