layout: page title: Release Notes
{% if site.version != “latest” %}
- Download
- Release Notes for Samza-{{site.version}} version
- Upgrade Notes
{% else %}
- Release Notes for Samza-{{site.version}} version
- Upgrade Notes {% endif %}
{% if site.version != “latest” %}
Download
All Samza JARs are published through Apache's Maven repository. See here for more details.
Source Release
samza-sources-{{site.version}}.tgz
{% endif %}
{% if site.version != “latest” %}
Release Notes {{site.version}}
{% else %}
Release Notes
{% endif %}
- SAMZA-1510 - Samza SQL
- SAMZA-1438 - Producer and consumer for Azure EventHubs
- SAMZA-1515 - Kinesis consumer
- SAMZA-1486 - Checkpoint provider for Azure tables
- SAMZA-1421 - Support for durable state in high-level API
- SAMZA-1392 - KafkaSystemProducer performance and correctness with concurrent sends and flushes
- SAMZA-1406 - Enhancements to the ZooKeeper-based deployment model
- SAMZA-1321 - Support for multi-stage batch processing
Upgrade Notes
Configuration Changes
- Introduced a new mandatory configuration -
job.coordination.utils.factory
. Read more about it here.
This config is applicable to all Samza applications deployed using the LocalApplicationRunner
(that is, non-yarn deployments).
API Changes
- The following APIs in
SystemAdmin
have been deprecated in the previous versions and hence, replaced with newer APIs. If you have a custom System implementation, then you have to update to the newer APIs.void createChangelogStream(String streamName, int numOfPartitions); -> boolean createStream(StreamSpec streamSpec);
void createCoordinatorStream(String streamName); -> boolean createStream(StreamSpec streamSpec);
void validateChangelogStream(String streamName, int numOfPartitions); -> void validateStream(StreamSpec streamSpec) throws StreamValidationException;
- New API has been added to
SystemAdmin
that clear a stream.
boolean clearStream(StreamSpec streamSpec);