IBM Message Hub Toolkit v3.3.2

IBM Message Hub Toolkit v3.3.2

What's new in this release and what has changed
This is a bug-fix release for log4j issue

IBM Message Hub Toolkit v3.3.1

What's new in this release and what has changed

This release upgrades the underlying Kafka toolkit from version 3.2.0 to 3.2.2 and inherits fixes from the new Kafka toolkit version.

Especially, the new toolkit version allows to consume multiple topics from a submission time parameter, like this:

stream <MessageType.StringMessage> ConsumedRecords = MessageHubConsumer() {
    param
        topic: getSubmissionTimeValue("topics");
        ...
}

To subscribe to the three topics "topic1", "topic2", and "topic3", the application can be submitted with the command

streamtool submitjob <sab file> -P topics=topic1,topic2,topic3

For all changes in this toolkit, please see the CHANGELOG.
For all changes in the underlying Kafka toolkit, please see the CHANGELOG of streamsx.kafka 3.2.2.

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

IBM Message Hub Toolkit v3.3.0

What's new in this release and what has changed

This release upgrades the underlying Kafka toolkit from version 3.1.3 to 3.2.0, which uses the Kafka client version 2.5.1. This client version includes bugfixes and supports incremental cooperative rebalancing for Kafka consumers (KIP-429), which has advantages for large consumer groups.

For details, how to activate this feature, please see the MessageHubConsumer in the SPL documentation.

For all changes in this toolkit, please see the CHANGELOG.
For all changes in the underlying Kafka toolkit, please see the CHANGELOG of streamsx.kafka 3.2.0.

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

IBM Message Hub Toolkit v3.2.2

What's new in this release and what has changed

This toolkit is a bugfix release.
The underlying Kafka toolkit has been upgraded from version 3.1.0 to the bugfix release 3.1.3.

For all changes in this toolkit, please see the CHANGELOG.
For all changes in the underlying Kafka toolkit, please see the CHANGELOG of streamsx.kafka 3.1.3.

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

IBM Message Hub Toolkit v3.2.1

What's new in this release and what has changed

This toolkit release does not deliver the vulnerable version of log4j.jar (#114) anymore.
There are no changes compared with the previous release v3.2.0.

The underlying Kafka toolkit of this release is version 3.1.0.

For all changes in this toolkit, please see the CHANGELOG.
For all changes in the underlying Kafka toolkit, please see the CHANGELOG of streamsx.kafka.

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

IBM Message Hub Toolkit v3.2.0

What's new in this release and what has changed

This toolkit release adds the new startPositionStr parameter to the MessageHubConsumer 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 consumer operator.

The underlying Kafka toolkit of this release is version 3.1.0.

For all changes in this toolkit, please see the CHANGELOG.
For all changes in the underlying Kafka toolkit, please see the CHANGELOG of streamsx.kafka.

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

IBM Message Hub Toolkit v3.1.0

What's new in this release and what has changed

This toolkit release adds the new staticGroupMember parameter to the MessageHubConsumer operator. This parameter can be used in all Event Streams plans that support Kafka 2.3. For the feature support of various plans, see https://cloud.ibm.com/docs/EventStreams?topic=EventStreams-plan_choose .

The underlying Kafka toolkit of this release is version 3.0.4, and has not changed.

For all changes in this toolkit, please see the CHANGELOG.
For all changes in the underlying Kafka toolkit, please see the CHANGELOG of streamsx.kafka.

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

IBM Message Hub Toolkit v3.0.4

What's new in this release and what has changed

This toolkit is a bugfix release, which is based on the Kafka toolkit 3.0.4.

The underlying Kafka toolkit fixes following issues, which are relevant for the Message Hub toolkit:

• Kafka toolkit 208 - KafkaProducer: message or key attribute with underline causes error at context checker.
  All previous versions are affected by this issue.
• Kafka toolkit 203 - KafkaConsumer: assign output attributes via index rather than attribute name

Other fixes:

• #106 Build fails for sample ConsumerGroupWithConsistentRegion
• #105 Make main composites of samples public

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

IBM Message Hub Toolkit v3.0.3

What's new in this release and what has changed

This toolkit is a bugfix release, which is based on the Kafka toolkit 3.0.3.

The underlying Kafka toolkit fixes an issue in exception handling of the consumer:

• Kafka toolkit 198 - The "nConsecutiveRuntimeExc" variable never reaches 50 when exceptions occur

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

IBM Message Hub Toolkit v3.0.2

What's new in this release and what has changed

This toolkit is a bugfix release, which is based on the Kafka toolkit 3.0.2.
The underlying Kafka toolkit adds new translated messages.

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