Toolkit com.ibm.streamsx.messagehub 3.3.1

Message Hub (Event Streams) Toolkit > com.ibm.streamsx.messagehub 3.3.1

General Information

Overview

This toolkit integrates IBM Streams with the IBM Event Streams cloud service. This toolkit is a specialized version of the Kafka-Toolkit, which simplifies the setup for connecting to the cloud service.

Additional information

For changes in this toolkit release, see the change log in public Github

Version

3.3.1

Required Product Version

4.3.0.0

Indexes

Namespaces

Operators

Functions

Types

Namespaces

com.ibm.streamsx.messagehub

This SPL namespace contains the operators to connect with an instance of the IBM Event Streams cloud service.

Operators

• MessageHubConsumer
• MessageHubProducer

Functions

• createMessageAddTopic(rstring)
• createMessageAddTopicPartition(list<Control.TopicPartition>)
• createMessageAddTopicPartition(list<Control.TopicPartitionOffset>)
• createMessageAddTopicPartition(rstring, int32)
• createMessageAddTopicPartition(rstring, int32, int64)
• createMessageAddTopics(list<rstring>)
• createMessageRemoveTopic(rstring)
• createMessageRemoveTopicPartition(list<Control.TopicPartition>)
• createMessageRemoveTopicPartition(rstring, int32)
• createMessageRemoveTopics(list<rstring>)

Types

• Control.TopicPartition
• Control.TopicPartitionOffset
• MessageType.BlobMessage
• MessageType.ConsumerMessageMetadata
• MessageType.StringMessage
• MessageType.TopicPartition