---
title: Charmhub | Deploy Apache Kafka Connect - K8s using Charmhub - The Open Operator
  Collection
description: Deploy the latest version of Apache Kafka Connect - K8s as a Kubernetes
  Operator on any cloud.
url: https://charmhub.io/kafka-connect-k8s/docs/r-rev82
---

# Apache Kafka Connect - K8s

[Canonical](https://charmhub.io/publisher/data-platform "View all packages from Canonical")

* [Canonical](https://charmhub.io/publisher/data-platform "View all packages from Canonical")

Platform:

4/stable 18

```
juju deploy kafka-connect-k8s --channel 4/stable
```

[Learn to deploy on juju >](https://juju.is/docs/juju/manage-applications)

---

#### Relevant links

* [Homepage](https://github.com/canonical/kafka-connect-k8s-operator)

---

#### Contacts

##### Maintainers

+ [Canonical Data Platform](mailto:data-platform@lists.launchpad.net)

* [Submit a bug](https://github.com/canonical/kafka-connect-k8s-operator/issues)

---

Share your thoughts on this charm with the community on discourse.

[Join the discussion](https://discourse.charmhub.io/)

# Release 82

New revisions of [Charmed Apache Kafka](http://charmhub.io/kafka) and [Charmed Apache Kafka K8s](http://charmhub.io/kafka-k8s) have been published to their `3/stable` channels.

> Check the documentation on how to upgrade between minor versions on [VM](https://charmhub.io/kafka/docs/h-upgrade), and on [K8s](https://charmhub.io/kafka-k8s/docs/h-upgrade)

### [Highlights](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-highlights)

* **Upgraded Apache Kafka version from 3.6.1 → 3.9.0**
  + Check the official Apache Kafka [Version 3.7.0 release notes](https://archive.apache.org/dist/kafka/3.7.0/RELEASE_NOTES.html)
  + Check the official Apache Kafka [Version 3.8.0 release notes](https://archive.apache.org/dist/kafka/3.8.0/RELEASE_NOTES.html)
  + Check the official Apache Kafka [Version 3.9.0 release notes](https://archive.apache.org/dist/kafka/3.9.0/RELEASE_NOTES.html)
* **Added support for the KRaft consensus protocol, removing the need for Apache ZooKeeper**
  + Check the [documentation](https://charmhub.io/kafka/docs/h-kraft-mode) for a guide on setting up a KRaft cluster
* **Added support for partition rebalancing using Cruise Control**
  + Check the [documentation](https://charmhub.io/kafka/docs/t-reassign-partitions) for a tutorial on partition rebalancing and reassignment using [Cruise Control](https://github.com/linkedin/cruise-control)
* **Created the `karapace` and `karapace-k8s` charms as a drop-in replacement for Schema Registry**
  + Check the [documentation](https://charmhub.io/kafka/docs/h-manage-message-schemas) on how to manage message schemas using [Karapace](https://www.karapace.io/)
* **Upgraded Apache ZooKeeper version from 3.8.2 → 3.9.2**
  + Check the official Apache ZooKeeper [Version 3.9.0 release notes](https://zookeeper.apache.org/doc/r3.9.0/releasenotes.html)
* **Adding backup/restore support using S3**

### [Features](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-features)

* [DPE-2872](https://warthogs.atlassian.net/browse/DPE-2872) - feat: partition rebalancing with Cruise Control [#219](https://github.com/canonical/kafka-operator/pull/#219)
* [DPE-4328](https://warthogs.atlassian.net/browse/DPE-4328) - feat: support KRaft [#232](https://github.com/canonical/kafka-operator/pull/#232)
* [DPE-6574](https://warthogs.atlassian.net/browse/DPE-6574) - feat: support cross-model K8s relations with juju expose [#309](https://github.com/canonical/kafka-operator/pull/#309)
* [DPE-6260](https://warthogs.atlassian.net/browse/DPE-6260) - feat: trust multi-certificate ca-chains [#297](https://github.com/canonical/kafka-operator/pull/#297)
* [DPE-6636](https://warthogs.atlassian.net/browse/DPE-6636) - feat: support non-unit/port extra\_listeners [#315](https://github.com/canonical/kafka-operator/pull/#315)

### [Improvements](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-improvements)

* [DPE-4956](https://warthogs.atlassian.net/browse/DPE-4956) - test: stabilise integration tests [#229](https://github.com/canonical/kafka-operator/pull/#229)
* [DPE-5226](https://warthogs.atlassian.net/browse/DPE-5226) - refactor: make ‘broker’ the central relation [#244](https://github.com/canonical/kafka-operator/pull/#244)
* [DPE-5591](https://warthogs.atlassian.net/browse/DPE-5591) - refactor: rework status handling [#254](https://github.com/canonical/kafka-operator/pull/#254)
* [DPE-5945](https://warthogs.atlassian.net/browse/DPE-5945) - chore: rename expose\_external configuration option [#274](https://github.com/canonical/kafka-operator/pull/#274)
* [DPE-5553](https://warthogs.atlassian.net/browse/DPE-5553) - feat: don’t restart server on keystore/truststore updates [#272](https://github.com/canonical/kafka-operator/pull/#272)
* [DPE-5349](https://warthogs.atlassian.net/browse/DPE-5349) - feat: add internal user and SASL/SCRAM authentication [#284](https://github.com/canonical/kafka-operator/pull/#284)
* [DPE-6138](https://warthogs.atlassian.net/browse/DPE-6138) - chore: update zookeeper client lib [#282](https://github.com/canonical/kafka-operator/pull/#282)
* [DPE-6266](https://warthogs.atlassian.net/browse/DPE-6266) - chore: prepare charm for charmcraft 3 [#293](https://github.com/canonical/kafka-operator/pull/#293)
* [DPE-5232](https://warthogs.atlassian.net/browse/DPE-5232);[DPE-5233](https://warthogs.atlassian.net/browse/DPE-5233) - chore: support for scaling operations in KRaft mode (single & multi-app) [#281](https://github.com/canonical/kafka-operator/pull/#281)
* [DPE-6247](https://warthogs.atlassian.net/browse/DPE-6247) - test/cicd: stabalise int-test ci [#320](https://github.com/canonical/kafka-operator/pull/#320)

### [Bug fixes](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-bug-fixes)

* [DPE-4703](https://warthogs.atlassian.net/browse/DPE-4703) - chore: sync vm + k8s w. nodeport feature [#226](https://github.com/canonical/kafka-operator/pull/#226)
* [DPE-4951](https://warthogs.atlassian.net/browse/DPE-4951) - fix: re-enable prefixed topic names during relations [#227](https://github.com/canonical/kafka-operator/pull/#227)
* [DPE-5208](https://warthogs.atlassian.net/browse/DPE-5208) - fix: secure written znodes [#231](https://github.com/canonical/kafka-operator/pull/#231)
* [DPE-5218](https://warthogs.atlassian.net/browse/DPE-5218) - chore: enable compatibility with ZK restore feature [#243](https://github.com/canonical/kafka-operator/pull/#243)
* [DPE-5686](https://warthogs.atlassian.net/browse/DPE-5686) - test: fix flakey CI
* [DPE-5611](https://warthogs.atlassian.net/browse/DPE-5611) - fix: remove cruise-control metrics reporter if no balancer [#250](https://github.com/canonical/kafka-operator/pull/#250)
* [DPE-5826](https://warthogs.atlassian.net/browse/DPE-5826) - fix: remove lost+found from new storages [#275](https://github.com/canonical/kafka-operator/pull/#275)
* [DPE-6261](https://warthogs.atlassian.net/browse/DPE-6261) - fix: remove ‘/’ character from generated SANs for Digicert [#297](https://github.com/canonical/kafka-operator/pull/#297)
* [DPE-6498](https://warthogs.atlassian.net/browse/DPE-6498) - fix: gracefully handle rebalance action when role not set [#313](https://github.com/canonical/kafka-operator/pull/#313)
* [DPE-6547](https://warthogs.atlassian.net/browse/DPE-6547) - fix: KRaft multi-mode scaling bug on broker side [#319](https://github.com/canonical/kafka-operator/pull/#319)

## [Charmed Apache ZooKeeper](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-charmed-apache-zookeeper)

New revisions of [Charmed Apache ZooKeeper](http://charmhub.io/zookeeper) and [Charmed Apache ZooKeeper K8s](http://charmhub.io/zookeeper-k8s) have been published to their `3/stable` channels.

### [Features](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-features)

* [DPE-5216](https://warthogs.atlassian.net/browse/DPE-5216) - feat: S3 integration [#151](https://github.com/canonical/zookeeper-operator/pull/#151)
* [DPE-5987](https://warthogs.atlassian.net/browse/DPE-5987) - feat: add expose-external configuration option [#172](https://github.com/canonical/zookeeper-operator/pull/#172)
* [DPE-5438](https://warthogs.atlassian.net/browse/DPE-5438) - feat: enable digest auth [#173](https://github.com/canonical/zookeeper-operator/pull/#173)
* [DPE-6262](https://warthogs.atlassian.net/browse/DPE-6262) - feat: support TLS certificate chains [#181](https://github.com/canonical/zookeeper-operator/pull/#181)

### [Improvements](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-improvements)

* [DPE-3477](https://warthogs.atlassian.net/browse/DPE-3477) - chore: reload stores [#152](https://github.com/canonical/zookeeper-operator/pull/#152)
* [DPE-5373](https://warthogs.atlassian.net/browse/DPE-5373) - chore: create backup action [#156](https://github.com/canonical/zookeeper-operator/pull/#156)
* [DPE-5126](https://warthogs.atlassian.net/browse/DPE-5126) - chore: use admin server instead of the 4lw commands [#154](https://github.com/canonical/zookeeper-operator/pull/#154)
* [DPE-5373](https://warthogs.atlassian.net/browse/DPE-5373) - chore: implement list-backups action [#157](https://github.com/canonical/zookeeper-operator/pull/#157)
* [DPE-5549](https://warthogs.atlassian.net/browse/DPE-5549) - chore: enable TLS v1.2 for client communication [#161](https://github.com/canonical/zookeeper-operator/pull/#161)
* [DPE-5218](https://warthogs.atlassian.net/browse/DPE-5218) - chore: implement restore flow [#162](https://github.com/canonical/zookeeper-operator/pull/#162)
* [DPE-5874](https://warthogs.atlassian.net/browse/DPE-5874) - test/refactor: Unit test migration [#171](https://github.com/canonical/zookeeper-operator/pull/#171)

### [Bug fixes](https://charmhub.io/kafka-connect-k8s/docs/r-rev82#p-37703-bug-fixes)

* [DPE-5208](https://warthogs.atlassian.net/browse/DPE-5208) - fix: enforce client auth [#150](https://github.com/canonical/zookeeper-operator/pull/#150)
* [DPE-5463](https://warthogs.atlassian.net/browse/DPE-5463);[DPE-5462](https://warthogs.atlassian.net/browse/DPE-5462) - fix: quote SERVER\_JVMFLAGS, safe rm tls files [#160](https://github.com/canonical/zookeeper-operator/pull/#160)
* [DPE-5462](https://warthogs.atlassian.net/browse/DPE-5462) - fix: handle NoNodeError during relation-broken [#168](https://github.com/canonical/zookeeper-operator/pull/#168)
* [DPE-6157](https://warthogs.atlassian.net/browse/DPE-6157) - fix: don’t erase previous records from /etc/hosts [#175](https://github.com/canonical/zookeeper-operator/pull/#175)

---