New to KubeDB? Please start here.
Kafka Volume Expansion
This guide will give an overview on how KubeDB Ops-manager operator expand the volume of various component of Kafka
like:. (Combined and Topology).
Before You Begin
- You should be familiar with the following
KubeDB
concepts:
How Volume Expansion Process Works
The following diagram shows how KubeDB Ops-manager operator expand the volumes of Kafka
database components. Open the image in a new tab to see the enlarged version.
The Volume Expansion process consists of the following steps:
At first, a user creates a
Kafka
Custom Resource (CR).KubeDB
Provisioner operator watches theKafka
CR.When the operator finds a
Kafka
CR, it creates required number ofPetSets
and related necessary stuff like secrets, services, etc.Each PetSet creates a Persistent Volume according to the Volume Claim Template provided in the petset configuration. This Persistent Volume will be expanded by the
KubeDB
Ops-manager operator.Then, in order to expand the volume of the various components (ie. Combined, Broker, Controller) of the
Kafka
, the user creates aKafkaOpsRequest
CR with desired information.KubeDB
Ops-manager operator watches theKafkaOpsRequest
CR.When it finds a
KafkaOpsRequest
CR, it halts theKafka
object which is referred from theKafkaOpsRequest
. So, theKubeDB
Provisioner operator doesn’t perform any operations on theKafka
object during the volume expansion process.Then the
KubeDB
Ops-manager operator will expand the persistent volume to reach the expected size defined in theKafkaOpsRequest
CR.After the successful Volume Expansion of the related PetSet Pods, the
KubeDB
Ops-manager operator updates the new volume size in theKafka
object to reflect the updated state.After the successful Volume Expansion of the
Kafka
components, theKubeDB
Ops-manager operator resumes theKafka
object so that theKubeDB
Provisioner operator resumes its usual operations.
In the next docs, we are going to show a step-by-step guide on Volume Expansion of various Kafka database components using KafkaOpsRequest
CRD.