Start processing event streams using local test server
This function requires Streaming Data Framework for MATLAB® Production Server™ and MATLAB Compiler SDK™.
start( starts processing event streams
using a local test server (development version of MATLAB
Production Server) running at the default hostname
localhost and port number
9910. Asynchronous event processing started with the
continues until either the processor reaches the end of the stream or you explicitly call
Before starting event processing with
start, you must start the
local test server with
Start Processing Event Streams Using Local Test Server
Assume that you have a Kafka® server running at the network address
that has a topic
Also assume that you have a stateful streaming analytic function
recamanSum and initialization function
KafkaStream object connected to the
ks = kafkaStream("kafka.host.com",9092,"RecamanSequence");
EventStreamProcessor object that runs the
recamanSum function and is initialized by the
esp = eventStreamProcessor(ks,@recamanSum,@initRecamanSum);
Start the local test server, which also opens the Production Server Compiler (MATLAB Compiler SDK) app.
Start the test server from the app by clicking Test Client and then Start. For an example on how to use the app, see Test Client Data Integration Against MATLAB (MATLAB Compiler SDK).
Navigate back to the MATLAB command prompt to start processing events.
In the Production Server Compiler app, the test server receives data.
esp — Object to process event streams
Object to process event streams, specified as an
port — Port number on which test server is running
integer in range [0, 65,535]
Port number on which the test server is running, specified as an integer in the range [0, 65,535].
host — Hostname of machine on which local test server is running
string | character vector
Hostname of machine on which the local test server is running, specified as a string or character vector.
Introduced in R2022b