Version 2.8.1-2.3.1
Updates
- Upgrade the base tech version of Apache Kafka to
2.3.1. See Kafka’s Release Notes for 2.3.1 for details.
Improvements
- Improve status check to verify topic successfully created in Zookeeper. In case of failure, the service returns
500 INTERNAL_SERVER_ERRORinstead of200 OK.
Version 2.8.0-2.3.0
Updates
- Updated the SDK to version
0.57.0. For more information, see release notes for previous SDK releases:
New Features
- Added new CLI commands (PR #447):
dcos kafka topic configdcos kafka topic delete-configdcos kafka acl
- By upgrading the SDK, Kafka now comes with support for:
- Quota enforcement
- Node draining
Version 2.7.0-2.3.0
Updates
- Upgrade the base dcos-commons SDK version to
0.56.2. - Upgrade the base tech version of Apache Kafka to
2.3.0. See Kafka’s Release Notes for 2.3.0 for details. - Option to configure new listener config
max.connectionswhich limits the number of active connections on each listener.
New Features
- Added support for DC/OS Storage Service (DSS). See official DSS docs for more details.
- Added better broker health checks. Users can now select between a simple port based check or an advanced producer-consumer check based on a custom heartbeat topic.
Version 2.6.0-2.2.1
Updates
- Upgrade Kafka base tech to version
2.2.1. See Kafka’s Release Notes for details. - Upgrade the base dcos-commons SDK version to
0.56.1. - Oracle JDK is replaced by OpenJDK 8.
New Features
- Autosuggestion is available for Service Account and Secrets when launching the service from DC/OS UI
- Support for Secure JMX
- Added marathon service scheduler checks
- Service will fetch all required resources over HTTPS
Version 2.5.0-2.1.0
Important Notes
-
The
inter_broker_protocol_versionnow defaults to the newer2.1version. This has a few implications, as described below:- Kafka 1.1.0 supports
inter_broker_protocol_version:1.1maximum, and by default it is set to1.0. - Kafka 2.1.0 supports
inter_broker_protocol_versions up to2.1. - If you haven’t specified a
inter_broker_protocol_versionin your options file, the new default will be used and changed to2.1. This will cause downtime during the upgrade when some Kafka nodes will be on Kafka 1.1.0 usinginter_broker_protocol_version1.0and others will be on Kafka 2.1.0 using protocol2.1.
To avoid any potential downtime, change the protocol version used when upgrading Kafka.
-
Set up CLI to connect to a soak cluster
-
Update your
options_file.jsonwith the following contents:{ ... "kafka": { ... "inter_broker_protocol_version": "1.0" ... } ... } -
And update your service like so:
~$ dcos package install --cli --yes kafka ~$ dcos kafka --name=data-services/kafka update start \ --package-version=2.5.0-2.1.0 \ --options=options_file.json
- Kafka 1.1.0 supports
Updates
- Upgrade Kafka base tech to version 2.1.0. See Kafka’s Release Notes more for details.
- Upgrade Zookeeper Client version to 3.4.13.
Version 2.4.0-1.1.1
Updates
- Upgrade Kafka base tech to version 1.1.1. See Kafka’s Release Notes for details.
- Upgrade the base dcos-commons SDK version to 0.55.2.
- Upgrade Zookeeper Client version to 3.4.13.
New Features
- Number of open file descriptors is now configurable via the
RLIMIT_NOFILE_SOFTandRLIMIT_NOFILE_HARDconfiguration parameters. - Timeouts for readiness checks are now configurable via the
READINESS_CHECK_INTERVAL,READINESS_CHECK_DELAYandREADINESS_CHECK_TIMEOUTconfiguration parameters.
Version 2.3.0-1.1.0
Updates
- Upgrade Kafka base tech to version 1.1.0. See Kafka’s Release Notes for details.
Version 2.3.0-1.0.0
New Features
- Support for configuring Kafka transport encryption ciphers with secure defaults.
Version 2.2.0-1.0.0
New Features
- Support for using a custom top level domain to facilitate exposing the service securely outside of the cluster.
- Support for launching the service in a remote region.
Version 2.1.0-1.0.0
New Features
- Support for the automated provisioning of TLS artifacts to secure Kafka communication.
- Support for Kerberos and SSL authorization and authentication.
- Support for
Zoneplacement constraints in DC/OS 1.11. - Ability to pause a service pod for debugging and recovery purposes.
Updates
- Major improvements to the stability and performance of service orchestration.
- Protocol and log version defaults are also set to
1.0. - Improve Kafka’s ZK library to enable re-resolution as required on virtual networks
- Upgrade the JRE to 1.8u162
- The service now uses the Mesos V1 API. The service can be set back to the V0 API using the service property
service.mesos_api_version.
Version 2.0.4-1.0.0
Updates
- Upgraded to Kafka v1.0.0.
Version 2.0.3-0.11.0
Bug Fixes
- Uninstall now handles failed tasks correctly.
- Fixed a timing issue in the broker readiness check that caused brokers to be stuck in STARTING when the service is allocated more than 2 CPUs per broker.
Version 2.0.2-0.11.0
Bug Fixes
- Dynamic ports are no longer sticky across pod replaces
- Further fixes to scheduler behavior during task status transitions.
Improvements
- Updated JRE version to 8u144.
- Improved handling of error codes in service CLI.
Version 2.0.1-0.11.0
Bug Fixes
- Tasks will correctly bind on DC/OS 1.10.
Documentation
- Updated post-install links for package.
- Updated
limitations.md. - Ensured previous
version-policy.mdcontent is present.
Version 2.0.0-0.11.0
Improvements
- Based on the latest stable release of the dcos-commons SDK, which provides numerous benefits:
- Integration with DC/OS features such as virtual networking and integration with DC/OS access controls.
- Orchestrated software and configuration update, enforcement of version upgrade paths, and ability to pause/resume updates.
- Placement constraints for pods.
- Uniform user experience across a variety of services.
- Graceful shutdown for brokers.
- Update to 0.11.0.0 version of Apache Kafka (including log and protocol versions).
Breaking Changes
- This is a major release. You cannot upgrade to version 2.0.0-0.11.0 from a 1.0.x version of the package. To upgrade, you must perform a fresh install and replicate data across clusters.
Kafka Documentation