Getting Started

Apache Samza 0.12 [Docs]

We are excited to announce that the Apache Samza 0.12.0 has been released. It is a major release with several features; notably batch processing and enhancements to improve stability, performance and ease of use.

Enhancements and Bug Fixes

Overall, 30 JIRAs were resolve in this release. Here are few highlights

  • SAMZA-967 Add HDFS system consumer
  • SAMZA-1042 Allow offset notifications for input systems
  • SAMZA-1013 Support YARN node labels
  • SAMZA-1079 Add timeout for blocking reads when localizing containers
  • SAMZA-1077 Handle all exceptions and errors in container
  • SAMZA-1069 Deadlock between kafka system producer and kafka producer from kafka-clients lib
  • SAMZA-1065 Handle commit order correctly to guarantee at least once processing when using local store for dedup

Upgrade Notes

  • Upgraded Kafka version to 0.10. This enables us to take advantage of the critical fixes and improvements in Kafka.
  • Upgraded to Jetty 9 from Jetty 8.
  • Full support for Scala 2.11. All Samza jars will now have the scala version as 2.11 as a part of their file name. For example, samza-yarn_2.11-0.12.jar.
  • Samza is now source compatible with JDK 8 and above. Older JDKs are no longer supported.

Sources and Artifacts


For more details about this release, please check out the release blog post.