Toolkit com.ibm.streamsx.messagehub 3.0.2

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

What's new and what has changed

Version

3.0.2

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