While Apache Pulsar (incubating) shares some similarities with Apache Kafka, it has a different architecture. Namely, it has stateless brokers and separate storage bookies (services implemented via Apache BookKeeper). Data is stored as segments, which allow scale up without rebalancing. The post describes this architecture and compares with Kafka. Also of note: Pulsar provides a Kafka-compatible API, which aims to provide drop-in compatibility.
As Kubernetes seems to be gaining lots of traction for container orchestration, it’s pretty natural to try to run Spark jobs with it. This first post describes how to do so, and it describes some of the current shortcomings in the current implementation. The second looks at how to then integrate with Apache Zeppelin, which has a few gotchas.
Using Hue to interact with Apache Kylin
Apache Kylin is an OLAP database system for big data. It supports JDBC drivers, which can be used to run queries from Hue, including on an Amazon Elastic MapReduce setup. This post includes the basic steps to get going.
The Confluent blog has recently had several articles about the exactly once semantics in Apache Kafka. In the latest post in their series, they describe how the Kafka Streams API achieves exactly once
As I usually say, you should always validate a benchmark with your own use case, rather than trusting what you see online. This example helps to really drive home that point—a small bug in data production of a benchmark driver program caused a major slowdown for Apache Flink in a competitor’s analysis.
This post shows how to track Presto queries on a cluster by implementing an Event Listener class to log the contents of queries. The code is available on github, and there are instructions in the article for how to deploy the custom code via Amazon EMR.