Remove multiple-event-types-in-the-same-kafka-topic
article thumbnail

Streams Replication Manager Prefixless Replication

Cloudera

It is also important to have multiple options (like normal and prefixless replication) to do the replication process, since every solution has its own advantages. It is also important to have multiple options (like normal and prefixless replication) to do the replication process, since every solution has its own advantages.

article thumbnail

Data Reprocessing Pipeline in Asset Management Platform @Netflix

Netflix Tech

By Meenakshi Jindal Overview At Netflix, we built the asset management platform (AMP) as a centralized service to organize, store and discover the digital media assets created during the movie production. During this evolution, quite often we receive requests to update the existing assets metadata or add new metadata for the new features added.

Insiders

Sign Up for our Newsletter

This site is protected by reCAPTCHA and the Google Privacy Policy and Terms of Service apply.

article thumbnail

Fraud Detection With Cloudera Stream Processing Part 2: Real-Time Streaming Analytics

Cloudera

In part 1 of this blog we discussed how Cloudera DataFlow for the Public Cloud (CDF-PC), the universal data distribution service powered by Apache NiFi, can make it easy to acquire data from wherever it originates and move it efficiently to make it available to other applications in a streaming fashion. Use case recap.

Process 87
article thumbnail

A quick tour of data distribution technologies by David Hope

Scott Logic

Rather, I am talking here about asynchronously distributing data to other services that maintain their own copy of the data in order to do their work or where we want to emit and distribute events for other services to process. We’ll provide examples of each and discuss the tradeoffs that must be made.

article thumbnail

Async APIs - don't confuse your events, commands and state by David Hope

Scott Logic

In my previous blog post I looked at various technologies for sending data asynchronously between services including RabbitMQ, Kafka, AWS EventBridge. This time round I’ll look at the messages themselves which over the last few years I’ve found to be a more complex and nuanced topic than expected.

AWS 52
article thumbnail

Using Change Data Capture for Warehouse Analytics

Picnic Engineering

Pipeline overview Since the TS is an externally developed hardware and software system, Picnic cannot change it to expose analytics events directly. So how can we get our hands on events for analytical purposes if we cannot change the TS to expose them? It detects any changes made to a database and exposes them as events.

Kafka 52
article thumbnail

BPFAgent: eBPF for Monitoring at DoorDash

DoorDash Engineering

With these hooks, we can intercept and understand TCP and UDP connections across our multiple Kubernetes clusters. While we quickly confirmed the value of investing in developing BPFAgent, we also experienced multiple pain points related to this version’s poor development lifecycle and slow start-up times.

Bytes 83