adamrecsko opened a new pull request, #3782:
URL: https://github.com/apache/iggy/pull/3782
## Which issue does this PR address?
Relates to #3689
## Rationale
This is phase 1 of Apache Fluss connector support, enabling Apache Iggy
streams to write messages into Fluss.
## What changed?
Apache Iggy previously had no sink for writing messages to Apache Fluss.
The new sink writes binary, JSON, or text payloads to append-only Fluss log
tables, with optional Iggy metadata and
automatic table creation.
Writer buffering, retries, idempotence, SASL authentication, startup
validation, and Docker-backed integration tests are included.
## Local Execution
- Local checks passed except for full workspace Clippy
- Pre-commit hooks ran and passed
- Passed `cargo fmt --all`
- Passed `cargo sort --check --no-format --workspace`
- Passed focused Clippy for `iggy_connector_fluss_sink`
- Passed all 19 Fluss sink unit tests
- Passed the focused Docker-backed Fluss integration test
- Full workspace Clippy did not pass because of six unrelated existing
errors in `core/sdk` and one in `core/server`
## AI Usage
1. OpenAI Codex.
2. Used for implementation assistance, review remediation, test execution,
and PR wording.
3. Verified with formatting, dependency sorting, focused Clippy, unit
tests, Docker-backed integration testing, and pre-commit hooks.
4. Yes, I can explain every line of the code if asked.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
