Apache Kafka is a distributed messaging system providing fast, highly scalable and redundant messaging through a publisher-subscriber model. Apache Kafka is highly available and resilient to node failures and supports automatic recovery. Apache Kafka has provision of robust queue that can handle a high volume of data and has enabler to pass on the messages from one end point to another. Kafka is suitable for both offline and online message consumption. Apache Kafka is built on top of the Zookeeper synchronization service. All Kafka messages are organized into topics. It integrates very well with Apache Storm and Spark for real-time streaming data analysis.
TIBCO ActiveMatrix BusinessWorks Plug-in for Apache Kafka – Community Edition plugs into TIBCO ActiveMatrix BusinessWorks. Apache Kafka palette can be used to create producers, consumers and perform send message and receive message operations.
The plug-in provides the main features given below:
Kafka Connection Shared Resource
Kafka connection shared resource is used to connect and fetch the list of topics from Kafka server. The shared resource is used by the other activities for configuring the connection.
Kafka SendMessage Activity
This activity sends message to the Kafka consumer. This activity performs as Kafka producers which sends the message to a specified topic and consumer can fetch the message from the specified topics.
Kafka ReceiveMessage Activity
This activity is a process starter activity that starts the process based on the receipt of Kafka messages.