Skip to content

Update operator for Kafka Connect #1850

@MikeEdgar

Description

@MikeEdgar

To allow users to configure Kafka Connect in the Console CR, the CRD model, mapping process, and roles need to be updated in the operator module.

  • Using com.github.streamshub.console.config.KafkaConnectConfig (in common module) as the basis, add a KafkaConnect class to the operator's com.github.streamshub.console.api.v1alpha1.spec package and make a list of them configurable from the ConsoleSpec.
  • Update the operator's ConfigurationProcessor to map the model added above to the configuration model (in common). This will likely be similar to what is done in the addSchemaRegistries method.
  • Update RBAC
    • Update the role granted to the console in /src/main/resources/com/github/streamshub/console/dependents/console.clusterrole.yaml to allow kafkaconnects and kafkamirrormaker2s to for get/list/watch, similar to what was done in /install/operatorless/020-ClusterRole-console-server.yaml.
    • Update the operator's role in operator/src/main/kubernetes/kubernetes.yml in a similar way. The ClusterRole to change is streamshub-consolereconciler-additional-cluster-role. This allows the operator to delegate this access to the console deployments.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions