Repository navigation

feat: Kafka admin client - #1045

Open

labrenbe wants to merge 37 commits into

feat/kafka-agentfrom

feat/kafka-admin

Open

feat: Kafka admin client#1045
labrenbe wants to merge 37 commits into
feat/kafka-agentfrom
feat/kafka-admin

Commits on Oct 16, 2026
- add kafka admin client managing topics, topic config and partition count
  labrenbe
  committed
  c26dc42
- add support for list_partition_reassignments
  labrenbe
  committed
  87a5479
- replace kafka_error with semantic error checks in the kafka admin client
  labrenbe
  committed
  798619e
- remove is retryable checks for kafka errors
  labrenbe
  committed
  d0a7abb
- simplify kafka error handling
  labrenbe
  committed
  95581f0
Commits on Oct 20, 2026
- add a flag for topic already exists errors
  labrenbe
  committed
  69ed88e
Commits on Oct 21, 2026
- 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
Commits on Oct 23, 2026
Commits on Oct 26, 2026
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  b95fb0a
Commits on Oct 27, 2026
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  e0e76ed
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  51e863a
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  9549489
- 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
Commits on Oct 28, 2026
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  b435ce4
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  2f23562
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  cb10888
- retry broken connection requests immediatly with a new connection
  labrenbe
  committed
  a326d59
Commits on Oct 29, 2026
- 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-agent' into feat/kafka-admin
  labrenbe
  committed
  8ec0341
Commits on Nov 3, 2026
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  f14c358
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  6735148
- fix Cargo.toml
  labrenbe
  committed
  b4111e0
Commits on Nov 4, 2026
- 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
Commits on Nov 5, 2026
- Merge branch 'feat/kafka-agent' into feat/kafka-admin
  labrenbe
  committed
  53c0e8a
- Start the connect cooldown only after a slow failure
  labrenbe
  committed
  f8fe3c8

Commits

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