Kafka Toolkit v3.1.0

What's new and what has changed

New features in this release:

• #213 KafkaConsumer: dynamic startPosition parameter

This adds a new operator parameter startPositionStr to the KafkaConsumer operator. Its semantic is equivalent to the startPosition parameter, but it takes an expression of type rstring, so that a submission time parameter can be used for the start position of the operator.

Note for the new feature:

When the new startPositionStr parameter is set at submission time, a JobControlPlane operator must be added to the application graph, when the start position can be different from "Default" (what is why you would use this new feature). When time is also an option for the start position, the startTime parameter must be used. startTime will be ignored when the start position is not "Time". The JobControlPlane will not be used by the KafkaConsumer operator when the start position is the default start position. A sample can be found in GitHub here.

For all changes, please see the CHANGELOG

You find the SPL documentation at https://ibmstreams.github.io/streamsx.kafka/docs/user/SPLDoc/.