Prerequisites

Write Streaming Analytic MATLAB Function

For testing purposes, use the sample MATLAB functions recamanSum and initRecamanSum located in the support_package_root\mps\streaming\Examples\Numeric folder, where support_package_root is the root folder of support packages on your system. To get the path to this folder, use this command:

fullfile(matlabshared.supportpkg.getSupportPackageRoot,'toolbox','mps','streaming','Examples','Numeric')

Later, you test the recamanSum deployable archive using the local test server.

For details about the recamanSum and initRecamanSum functions and to access the code, see Write Stateful Function and Write State Initialization Function.

Create Sample Streaming Data

Prepare for testing by creating sample data and writing the data to a Kafka stream. For this example, you create a 1000-element Recamán sequence and write it to a Kafka topic recamanSum_data.

To create the Recamán sequence, you can use the following recamanTimeTable function, which is also located in the \Examples\Numeric folder. recamanTimeTable creates a timetable containing the first N elements of a Recamán sequence.

function tt = recamanTimeTable(N)
    rs = zeros(1,N);
    for k=2:N
        n = k-1;
        subtract = rs(k-1) - n;
        if  subtract > 0 && any(rs == subtract) == false
            rs(k) = subtract;
        else
            rs(k) = rs(k-1) + n;
        end
    end

    incr = seconds(1:N);

    thisVeryInstant = ...
        convertTo(datetime, "epochtime", "Epoch", "1970-1-1");
    thisVeryInstant = datetime(thisVeryInstant, "ConvertFrom",...
        "epochtime", "Epoch", "1970-1-1");

    thisVeryInstant.TimeZone = "UTC";
    timestamp = (thisVeryInstant - seconds(N)) + incr';

    key = (0:N-1)';
    key = string(key);
    R = rs';
    tt = timetable(timestamp,R,key);

end

You can use the following code to create a 1000-element Recamán sequence using the recamanTimeTable function and write it to the recamanSum_data Kafka topic. The example assumes that you have Kafka host running at the network address kafka.host.com:9092 and you have the necessary permissions to create topics in the Kafka cluster.

kafkaHost = "kafka.host.com";
kafkaPort = 9092;

tt0 = recamanTimeTable(1000);

dataKS = kafkaStream(kafkaHost, kafkaPort, "recamanSum_data", Rows=100);

try deleteTopic(dataKS); catch, end

writetimetable(dataKS, tt0);

tt1 = readtimetable(dataKS);

if isequal(tt0(1:height(tt1),:), tt1)
    fprintf(1,"Success writing data to topic %s.\n", dataKS.Name);
end

stop(dataKS);

Simulate Production Using Local Test Server

To simulate streaming data processing in a production environment, you can run the recamanSum deployable archive using the development version of MATLAB Production Server and process data from the recamanSum_data topic.