Docs Menu
Docs Home
/
Atlas
/

Atlas Stream Processing 변경 로그

  • Amazon Web Services Transit Gateway 를 사용하여 Amazon Web Services Confluent 클라우드 클러스터에 연결할 수 있도록 지원합니다. 자세히 학습 Kafka Transit Gateway 연결 추가를 참조하세요.

  • 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 호핑하도록 구성하지 못하는 문제를 수정합니다.

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

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

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

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

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

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

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

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

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

이 페이지의 내용