In Apama 10.3.1 we introduced the “Batch Accumulator” and the “Message List” codecs. Both of these codecs deal with handling batches of multiple events at the same time to support use cases with high event rates
The “Batch Accumulator” codecYou can easily add this codec to your connectivity plug-in chain, without changing anything else in your application or anything external, and it will allow events being sent from the connectivity transport to a correlator (host) to be batched.… Read More
The purpose of this blog post is to introduce new features that extend the HTTP Server Connectivity Plug-in with the ability to respond to a request from the EPL. Prior to 10.3.1 only a basic response was returned to indicate the call had succeeded. This change allows a full request and response protocol to be implemented.
Now, you can configure the HTTP Server transport to allow the response to an HTTP request to be created by an EPL application, instead of automatically returning an empty accepted response.… Read More
My goal with this blog post is to show how to set up Apama with Kafka and how they can be used together in a stream processing application. Kafka handles the transport and allows you to set up the delivery system, while Apama is a high performance event-processing engine with enough flexibility and throughput to provide for most applications. This blog post isn’t going to be a tutorial on Kafka, and I have used a containerized version of a Kafka cluster for simplicity.… Read More
Apama uses the concept of “bundles” to provide the ability to add connectivity such as Kafka or MQTT to the project, and also for adding EPL capabilities such as date/time formatting. Until now, the only way to create a project and add these bundles was using the Software AG Designer graphical environment, which is only supported on Windows.
However, now we have a new tool called apama_project that enables all this functionality from the command line, on Linux as well as Windows.… Read More
The latest version of Apama Community Edition has arrived bringing dynamic HTTP server responses, command line tooling for managing Apama projects and general connectivity improvements.… Read More
In this blog, we will look at how we can use Apama running on the Raspberry Pi to act as a “Thin Edge” device, and integrate it with Cumulocity IoT Cloud.
A “Thin Edge” platform is designed to handle a potentially large amount of data generated by sensors/devices, perform additional analytics on that data, and then communicate the results (e.g. calculated aggregate values, alarms, etc.) back to a “Thick Edge”/Cloud deployment. … Read More