Atlas Stream Processing 변경 로그

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

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

hopSize 가 interval보다 큰 호핑 기간을 구성하지 못하는 문제를 수정합니다.

executionTimeSecs executionTimeMillis통계를 로 변경합니다. 이 통계를 보려면 sp.processor.stats() 명령을 호출합니다.

Apache Kafka 싱크에 대한 의 버퍼링 지속 시간을 $emit 1000 밀리초에서 5 밀리초로 변경합니다.

AWS에서 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 Atlas Stream Processing Stream Apache Kafka Processing 이 string Apache Kafka 오류를 문자열로 직렬화하는 방식을 표준화합니다.

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

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

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

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

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

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