After months of testing efforts and seven voting rounds, Apache Kafka 0.10.0 and the corresponding Confluent Platform 3.0 have been finally released, cheers!
- Kafka 0.10.0 is the newest major release of Apache Kafka, which includes more than 400 JIRAs and 13 KIPs, including Kafka Streams — a simple solution for stream processing, Message Timestamps — an additional field inside the message that enables log retention and rolling as well as stream processing based on event-time, Rack Awareness — functionality to assign replicas to brokers so they can span multiple racks or availability zones, and many other new features.
- Confluent Platform 3.0 introduces the first commercial product through the Confluent Platform Enterprise offering — Control Center, for comprehensive management and monitoring of Apache Kafka. Read this page to compare Apache Kafka, Confluent Platform, and Confluent Enterprise.
- Videos and slides from Kafka Summit 2016 have been made available!
- Ismael Juma joins Apache Kafka community as the 14th committer, welcome Ismael!
- Kafka Connect contributions have been growing rapidly over the past month! Checkout this new hub for available certified connectors.
- Thanks to Yelp for hosting the Kafka Meetup this month! Enrico Canzonieri and Usman Masood gave great presentations on operating Kafka at scale and executing continuous SQL queries on top of Kafka, respectively.
- Ewen Cheslack-Postava from Confluent talked about how to stream data integration with Kafka Connect at Apache Big Data 2016.
- Martin Kleppmann compares using event streams and Kafka for keeping data in sync across heterogeneous systems with distributed transactions.
- Parth Brahmbhatt from Hortonworks talked about how to secure Kafka clusters.
- If you want to learn more about applying Kafka for real-time data analysis, read this article for a production use case in online anomaly detection, and also this talk about using Kafka and Samza for spam detection, and also this blog post about using Kafka and Flink to migrate your batch jobs to streaming.
- Why Apache Beam for stream processing? Checkout Google and data Artisan’s perspectives.
- Exciting news from Apache Calcite to extend SQL and relational algebra in order to support streaming queries.
Question on Log Retention:
Can we retain Kafka Topic log based on message version, i.e. if my Kafka topic is based on Customer profile, i want to retain current version and a prior version of a customer profile record based on CustomerId.
Thanks in advance.