Main Content

이벤트 스트림 처리

Kafka® 이벤트와 같은 이벤트를 읽고 쓰기

Streaming Data Framework for MATLAB® Production Server™를 설치하면 다음과 같은 작업이 가능합니다.

  • 이벤트 스트리밍 플랫폼에서 Kafka 이벤트와 같은 이벤트 스트림을 읽고 씁니다.

  • 프로덕션 환경을 시뮬레이션하여 스트리밍 분석 알고리즘을 테스트합니다. (MATLAB Compiler SDK™ 필요)

  • 스트리밍 분석 알고리즘을 배포하여 스케일링합니다. (MATLAB Production Server 필요)

MATLAB 애드온 탐색기에서 Streaming Data Framework for MATLAB Production Server 지원 패키지를 설치하십시오. 애드온 설치에 대한 자세한 내용은 애드온을 받고 관리하기 (MATLAB) 항목을 참조하십시오.

함수

모두 확장

kafkaStreamCreate connection to event stream in Kafka topic (R2022b 이후)
inMemoryStreamCreate connection to event stream hosted by MATLAB without schema processing applied (R2022b 이후)
testStreamCreate connection to event stream hosted by MATLAB with schema processing applied (R2022b 이후)

기본적인 가져오기 및 내보내기

readtimetableRead timetable from event stream (R2022b 이후)
writetimetableWrite timetable to event stream (R2022b 이후)
seekSet read position in event stream (R2022b 이후)
previewPreview subset of events from event stream (R2022b 이후)
identifyingNameEvent stream name (R2022b 이후)

가져오기 및 내보내기 옵션

detectImportOptionsCreate import options based on event stream content (R2022b 이후)
eventStreamImportOptionsCreate options for importing events from stream into MATLAB (R2022b 이후)
ImportOptionsImport options for event stream (R2022b 이후)
getvartypeData types used to export variables to stream (R2022b 이후)
setvartypeSet data types used to import and export variables to stream (R2022b 이후)
detectExportOptionsCreate export options based on event stream content (R2022b 이후)
ExportOptionsExport options for event stream (R2022b 이후)
readeventsRead raw events from Kafka stream without schema processing applied (R2022b 이후)
flushReset read window boundaries (R2022b 이후)
stopStop processing event streams from Kafka topic (R2022b 이후)
createTopicCreate topic in Kafka cluster (R2022b 이후)
deleteTopicRemove topic from Kafka cluster (R2022b 이후)
loggederrorError information for Kafka stream operation (R2022b 이후)
categoryListKafka stream provider property list (R2022b 이후)
getProviderPropertiesKafka stream configuration property data (R2022b 이후)
setProviderPropertiesSet properties specific to Kafka configuration (R2022b 이후)
isPropertyDetermine if Kafka stream provider property is set (R2022b 이후)
eventStreamProcessorApply stream analytic function to event stream (R2022b 이후)
executeExecute event stream processing function on specific number of event windows (R2022b 이후)
packagePackage stream processing function into deployable archive configured by EventStreamProcessor (R2022b 이후)
seekSet position in event stream to begin processing events (R2022b 이후)
startStart processing event streams using local test server (R2022b 이후)
startServerStart local test server (R2022b 이후)
stopStop processing event streams using local test server (R2022b 이후)
stopServerShut down local test server (R2022b 이후)
streamingDataCompilerPackage stream processing function into deployable archive (R2022b 이후)

도움말 항목

이벤트 스트림 처리하기

스트리밍 분석 함수 테스트 및 배포하기

문제 해결

Obtain Kafka Event Stream Log Files

Locate event stream log files to help with debugging issues.