Repository navigation

feat: KafkaTopic controller - #1050

Open

labrenbe wants to merge 141 commits into

mainfrom

feat/kafka-topic

Open

feat: KafkaTopic controller#1050
labrenbe wants to merge 141 commits into
mainfrom
feat/kafka-topic

Commits on Sep 24, 2026
- Add agent-binary as workspace member
  labrenbe
  committed
  578d2c7
- deploy the agent if spec.platformAcces.enabled is configured
  labrenbe
  committed
  2a1fae0
- add agent image and cluster role to Helm chart
  labrenbe
  committed
  f15777c
- build a separate agent image
  labrenbe
  committed
  ed51b0e
- Merge remote-tracking branch 'origin/main' into feat/kafka-agent
  labrenbe
  committed
  f01e5ce
- run ghs build for matrix of operator and agent
  labrenbe
  committed
  9507079
Commits on Oct 1, 2026
- move staged framework code to operator-rs
  labrenbe
  committed
  177cfb1
Commits on Oct 2, 2026
- fix issues identified by Claude
  labrenbe
  committed
  7f6d5a1
Commits on Oct 6, 2026
- add support for anonymous access via operator-rs
  labrenbe
  committed
  e5f431b
Commits on Oct 13, 2026
- use versioned for platform access CRD fragments
  labrenbe
  committed
  18a4ff2
Commits on Oct 16, 2026
- add kafka admin client managing topics, topic config and partition count
  labrenbe
  committed
  c26dc42
- add shared crate with shared constants and client security enum
  labrenbe
  committed
  c65a16c
- add KafkaTopic CRD
  labrenbe
  committed
  41db2c7
- add necessary envs and volumes to agent pod
  labrenbe
  committed
  fe5203f
- reject zookeeper-mode when platformAccess is configured
  labrenbe
  committed
  9ba595d
- add config to agent: bootstrap servers from discovery cm, security mode, tls paths
  labrenbe
  committed
  2c730ca
- add stackable-kafka-adminto workspace dependencies
  labrenbe
  committed
  5463640
- add support for list_partition_reassignments
  labrenbe
  committed
  87a5479
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  6a8e1b9
- replace kafka_error with semantic error checks in the kafka admin client
  labrenbe
  committed
  798619e
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  e7d4248
- remove is retryable checks for kafka errors
  labrenbe
  committed
  d0a7abb
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  c02eeb5
- simplify kafka error handling
  labrenbe
  committed
  95581f0
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  559fb04
Commits on Oct 20, 2026
- add a flag for topic already exists errors
  labrenbe
  committed
  69ed88e
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  248c918
Commits on Oct 21, 2026
- add kafka controller
  labrenbe
  committed
  e61fcdb
- use the recreate strategy for the agent deployment
  labrenbe
  committed
  773d3bd
- ship agent binary in operator image
  labrenbe
  committed
  679a24a
- Merge remote-tracking branch 'origin/main' into feat/kafka-agent
  labrenbe
  committed
  0a9ce61
- cleanup & only watch deployments with agent labels
  labrenbe
  committed
  85716c9
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  8241cb3
- use BrokerAddress in more places and remove awaiting_response
  labrenbe
  committed
  58e3393
- fix flaky unit test
  labrenbe
  committed
  198e800
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  ccf2fff
Commits on Oct 23, 2026
Commits on Oct 26, 2026
- use AgentResourceNames from operator-rs
  labrenbe
  committed
  87a290e
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  b95fb0a
- Merge branch 'main' into feat/kafka-agent
  labrenbe
  authored
  469caf2
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  bdc7e9f
- update the CRD to reflect operator-rs changes and the CRD decision
  labrenbe
  committed
  f094a23
- rewrite the topic agent for the new KafkaTopic CRD
  labrenbe
  committed
  d028aa2
Commits on Oct 27, 2026
- update operator-rs
  labrenbe
  committed
  61b1005
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  e0e76ed
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  bed3c7f
- replace hard-coded selectors on agent deployment with util from operator-rs
  labrenbe
  committed
  66bf00b
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  51e863a
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  4994c9f
- add topic_controller to operator for cleaning up after agents
  labrenbe
  committed
  624bebd
- use headless service to connect to bootstrap servers
  labrenbe
  committed
  14f9ee8
- rename cb_agent to container_builder_agent
  labrenbe
  committed
  cbde956
- add deref tests for new constants
  labrenbe
  committed
  e5e54fd
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  9549489
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  6ae37ee
- read bootstrap servers from KAFKA_BOOTSTRAP_SERVERS in the agent and create client only once
  labrenbe
  committed
  ac90b9f
- skip planning while the KafkaTopic reconciliation is paused
  labrenbe
  committed
  3fb16de
- watch only the KafkaTopics of the agent's cluster via a field selector
  labrenbe
  committed
  b3e247d
- reject topic names starting with __ (internal topics)
  labrenbe
  committed
  6b93004
- fix topic name immutability validation
  labrenbe
  committed
  57b853b
- regenerate-nix
  labrenbe
  committed
  42d02bf
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  e7d2299
- return only topic-level config and no source
  labrenbe
  committed
  150886f
- document source of magic kafka numbers
  labrenbe
  committed
  56b9894
- use ApiKey enum
  labrenbe
  committed
  1aee2b0
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  5941693
Commits on Oct 28, 2026
- change controller and CRD to use status.config without source
  labrenbe
  committed
  41f8b37
- add grace period before operator takes over topic status
  labrenbe
  committed
  f1946f7
- add docs and changelog entry
  labrenbe
  committed
  8b8934c
- bump operator-rs
  labrenbe
  committed
  bdda9d0
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  b435ce4
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  2e92a9e
- regenerate nix
  labrenbe
  committed
  3fab703
- test correct namespace deletion
  labrenbe
  committed
  0c7956b
- add OPA to management access test
  labrenbe
  committed
  0d1d0ac
- regenerate nix
  labrenbe
  committed
  a89b5db
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  2f23562
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  e780967
- regenerate nix
  labrenbe
  committed
  43657d4
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  cb10888
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  7da2ba8
- remove OPA from docs and test
  labrenbe
  committed
  f539947
- write status if failing during finalizer reconciliation
  labrenbe
  committed
  0f39003
- improve docs on deletion
  labrenbe
  committed
  d4cb53a
- report a stopped Kafka cluster as unavailable
  labrenbe
  committed
  c0f9338
- derive the topic configs from the applied changes
  labrenbe
  committed
  08c6a41
- add pull secret to docs
  labrenbe
  committed
  b5be3c1
- remove the unreachable throttle filter from the planned config changes
  labrenbe
  committed
  77eb95a
- clarify the test-support feature of the shared crate
  labrenbe
  committed
  af91710
- document that the admin client serializes the Kafka requests
  labrenbe
  committed
  45b8a8c
- retry broken connection requests immediatly with a new connection
  labrenbe
  committed
  a326d59
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  2229bec
Commits on Oct 29, 2026
- update operator-rs
  labrenbe
  committed
  f579456
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  048ff91
- improve broker address Display impl
  labrenbe
  committed
  28efc85
- build the tls config once instead of per-server
  labrenbe
  committed
  82f8950
- keep the connection if only the version check fails
  labrenbe
  committed
  1937b53
- rename helpers and doc comments to be more descriptive
  labrenbe
  committed
  b00fe65
Commits on Oct 30, 2026
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  c4422a6
- trim kuttl tests
  labrenbe
  committed
  c475bdb
- add keep environment util to topic test
  labrenbe
  committed
  45d37f3
- Merge remote-tracking branch 'origin/main' into feat/kafka-agent
  labrenbe
  committed
  8b7c86d
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  8ec0341
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  bdf8353
Commits on Nov 3, 2026
- Merge remote-tracking branch 'origin/main' into feat/kafka-agent
  labrenbe
  committed
  78c0344
- use stackable-operator 0.122.0
  labrenbe
  committed
  cc89f97
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  f14c358
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  a28ec57
- add readiness and liveness probes
  labrenbe
  committed
  efb02c4
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  6735148
- fix Cargo.toml
  labrenbe
  committed
  b4111e0
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  c2272bd
Commits on Nov 4, 2026
- regenerate nix
  labrenbe
  committed
  aab52d9
- Try every address of a bootstrap server when connecting
  labrenbe
  committed
  d5eeca9
- Skip connecting for 30 s after all bootstrap servers failed
  labrenbe
  committed
  187fe58
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  67d52a5
Commits on Nov 5, 2026
Commits on Nov 6, 2026
- update serde-saphyr to 2.1.1. 2.1.0 was yanked
  labrenbe
  committed
  e60b478
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  0bb764a
- Merge branch 'feat/kafka-admin' into feat/kafka-topic
  labrenbe
  committed
  55fa30b
- Merge remote-tracking branch 'origin/main' into feat/kafka-topic
  labrenbe
  committed
  d7355f8

Commits

Commits on Sep 24, 2026

Commits on Oct 1, 2026

Commits on Oct 2, 2026

Commits on Oct 6, 2026

Commits on Oct 13, 2026

Commits on Oct 16, 2026

Commits on Oct 20, 2026

Commits on Oct 21, 2026

Commits on Oct 23, 2026

Commits on Oct 26, 2026

Commits on Oct 27, 2026

Commits on Oct 28, 2026

Commits on Oct 29, 2026

Commits on Oct 30, 2026

Commits on Nov 3, 2026

Commits on Nov 4, 2026

Commits on Nov 5, 2026