Real-time stream processing with Hazelcast and Pulsar

• spring-pulsar-airquality

  2 4 10.0 Java

• pulsar-airquality-function

  1 3 10.0 Java

  pulsar-airquality-function

Source: https://github.com/tspannhw/pulsar-airquality-function

• InfluxDB

  www.influxdata.com featured

  Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.

  

• hazelcast-jet-contrib

  1 21 10.0 Java

  Extension modules for Hazelcast Jet

  

In order to process the data collected, we used theHazelcast Pulsar connector module to ingest data from Pulsar topics (note: you can use the same connector to write to Pulsar topics). Using Hazelcast allows us to compute various aggregation functions (sum, avg etc.) in real time on a specified window of stream items. The Pulsar connector uses the Pulsar client library, which has two different ways of reading messages from a Pulsar topic. These are Consumer API and Reader API, both use the builder pattern (for more informationclick here).

• Hazelcast

  7 5,875 9.9 Java

  Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.

  

Join the Hazelcast Slack andHazelcast Github repository.

• pulsar-hazelcast-airquality

  2 1 10.0 Java

  Apache Pulsar -> Hazelcast / Jet

• SpeakerProfile

  5 11 7.2

  My speaker profile for events and conferences based on codepo8/presenter-terms

Suggest a related project