Skip to main content

Enrich

This is the technical documentation for the enrichment step. If you are not familiar yet with this step of the pipeline, please refer to this page.

Here is the list of the enrichment assets:

enrich-kinesis (AWS)โ€‹

Standalone JVM application that reads collector payloads events from a Kinesis stream and outputs back to Kinesis.

enrich-pubsub (GCP)โ€‹

Standalone JVM application that reads collector payloads from a PubSub subscription and outputs back to PubSub.

enrich-kafka (cloud agnostic)โ€‹

Standalone JVM application that reads collector payloads from a Kafka topic and outputs back to Kafka.

enrich-rabbitmq-experimental (cloud agnostic)โ€‹

Standalone JVM application that reads collector payloads from a RabbitMQ subscription and outputs back to RabbitMQ.

stream-enrich-kafka (cloud agnostic)โ€‹

Standalone JVM application that reads collector payloads from a Kafka topic and outputs back to Kafka.

caution

In the near future, this app will get deprecated in favor of enrich-kafka.

stream-enrich-kinesis (AWS)โ€‹

Standalone JVM application that reads collector payloads from a Kinesis stream and outputs back to Kinesis.

caution

In the near future, this app will get deprecated in favor of enrich-kinesis.