Build Predictive Machine Learning with Flink | Workshop on Dec 18 | Register Now

Featured Partner: Platformatory

Reflexive Eventing for Data-Driven Applications

Platformatory created EventCeption which integrates with API transactions to generate domain events, making them available in multiple formats for consumption.

Partner use case - Build with Confluent badge

Synthesize, Aggregate, and Distribute Events in Various Formats



Modern applications and infrastructure produce billions of events of interest. These can include:

  • Business “Domain” Events
  • RESTful Service & RPC Events
  • Network & Infrastructure Events

It’s important to capture these events and share them with the right stakeholders. In an API context, this typically involves the service performing a dual write to the database and the message broker or passing the same changes through to the message broker using an approach like change data capture.

However, these approaches suffer from one of two limitations:

  1. Dual writes are complicated to achieve and require sensitive code changes. Many times, these may be legacy applications or outside our domain of control.
  2. Approaches such as CDC capture row-level changes, but piecing back domain objects from table and row-level changes requires extensive stream processing.

Eventception solves these limitations by treating the API history as a transactional log. It hooks into common network layer proxies and agents to synthesize, aggregate, and distribute events in various formats.

Eventception is an ideal platform for various use cases, such as:

Generic, Durable Event Ingestion (Both Push and Pull)

Eventception can be used to ingest events from various L4-L7 proxies, network logging appliances, or existing syslog agents. It has support for REST/HTTP style application services, gRPC, HTTP/2, and WebSockets.

Pre-aggregation and Filtering

Eventception can be used to parse, pre-aggregate, and filter data using an idiomatic DSL to summarize, roll up, and efficiently manage massive volumes of data over time.

Forwarding Data to Various Systems

Data can be forwarded to various systems using connectors, which support popular SIEM systems, log-storage systems, and analytical data stores. Eventception also supports consuming with Kafka consumers, REST, or a built-in webhook dispatcher, along with CloudEvent bindings (serverless friendly).

API Auditing & Forensics

Eventception has the ability to mine granular audit logs for RESTful microservices across your entire API surface.

Advanced Observability

Support for Open Telemetry APIs for handling logs, trace, and metrics.

Build with Confluent

This use case leverages the following building blocks in Confluent Cloud:

Reference Architecture



Resources

Contact Us

Contact Platformatory to learn more about this use case and get started.