Skip to content

Conversation

@jshearer
Copy link
Contributor

No description provided.

@jshearer jshearer changed the title Dekaf E2E WIP Dekaf E2E Testing WIP Dec 15, 2025
@jshearer jshearer force-pushed the dekaf/e2e_tests_2 branch 4 times, most recently from e268318 to c4e5ad5 Compare December 15, 2025 19:26
@jshearer jshearer self-assigned this Dec 16, 2025
@jshearer jshearer force-pushed the dekaf/e2e_tests_2 branch 3 times, most recently from 03eb0e7 to 35f5d65 Compare December 17, 2025 23:06
Dekaf previously required TLS and MSK IAM authentication for all upstream
Kafka connections, making local development and testing difficult. This adds
support for plaintext connections via URL scheme detection:

* `tcp://host:port` connects without TLS, `tls://host:port` uses TLS (default)
* `--upstream-no-auth` flag skips SASL authentication entirely
* `KafkaClientAuth::from_msk_region(None)` creates no-auth mode

Example local usage:
  dekaf --default-broker-urls tcp://localhost:29092 --upstream-no-auth ...
Run Dekaf e2e tests as separate step because `nexttest-run` messes with local stack state
* Make `local:data-plane` idempotent
* `ci:dekaf-e2e` now assumes `local:stack` etc are up rather than explicitly depending on it
* mise: log systemd output if failure
* mise: also log agent logs on failure
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants