Streaming Cassandra into Kafka presented by Yelp! | DataStax

Yelp has built a robust stream processing ecosystem called Data Pipeline. As part of this system we created a Cassandra Source Connector, which streams data updates made to Cassandra into Kafka in real time. We use Cassandra CDC and leverage the stateful stream processing of Apache Flink to produce a Kafka stream containing the full content of each modified row, as well as its previous value. About DataStax Accelerate: DataStax delivers the world’s only active everywhere database for hybrid cloud. DataStax Accelerate is the best opportunity in the world to learn from a community that builds and uses DataStax, contributes to Cassandra, and uses both to support the world’s largest web-scale applications across any cloud. To find out when registration opens for DataStax Accelerate 2020, please visit datastax.com/accelerate About DataStax: DataStax delivers the always-on, active-everywhere distributed hybrid cloud database built on Apache Cassandra™. The foundation for full data autonomy and personalized, real-time applications at scale, DataStax Enterprise makes it easy for enterprises to exploit hybrid and multi-cloud environments via a seamless data layer that eliminates the issues that typically come with deploying applications across multiple on-premises data centers and/or multiple public clouds. We help many of the world’s leading brands across industries transform their businesses by eliminating data silos and powering modern, mission-critical applications. For more information, visit www.DataStax.com and follow us on @DataStax. #apachecassandra #nosql #hybridcloud Website: www.datastax.com LinkedIn: www.linkedin.com/company/datastax Twitter: www.twitter.com/datastax Facebook: www.facebook.com/datastax