Geode

Integrate with distributed caching for complex use cases needing high availability

Overview

Joule’s Geode Publisher Transport leverages Apache Geode as a high-performance, distributed event transport, ideal for complex, high-availability use cases.

This system distributes events across a Geode cluster for further processing with minimal latency, high concurrency and reliable transaction support.

Geode's shared-nothing architecture ensures database-like consistency while maintaining low-latency performance. This robust architecture, deployed in production for over 15 years, has proven effective for large-scale enterprise solutions that demand both scalability and resilience.

Driver details: org.apache.geode:geode-core:1.15.1

Example & DSL attributes

This example configures the Geode Publisher to connect to a local Geode cluster (address localhost, port 10334).

It uses employee_id as the key to identify records in the employees region.

Data is serialised with the PDX format, which is efficient for distributed caching and allows for compatibility across Geode clients.

geode publisher:
  connection:
    locator address: localhost
    locator port: 10334

  key: employee_id
  region: employees
  serialization type: PDX

Attributes schema

Attribute	Description	Data Type	Required
connection	Cluster connection details	See Connection attributes
key	Key attribute	String Default: uuid
region	Storage target region	String Default: streamEvents
serialization type	Serialisation method to use. See serialisation section	Enum Default: PDX

Additional resources

• To learn more about Apache Geode, see the documentation