Atlas Stream Processing 변경 로그

AWS에서 Confluent를 사용한 VPC 피어링 을 지원합니다.

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

Confluent로 AWS PrivateLink 를 지원합니다.

EventHubs를 통해 Azure Private Link 를 지원합니다.

Apache Kafka 시간 제한을 10 초에서 초로 30 늘립니다.

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

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

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

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

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

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

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

컬렉션 없는 $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를 통해 특정 리전에서 스트림 처리 인스턴스를 생성할 수 없었던 버그를 수정합니다.