AmalenduManoj opened a new pull request, #4381:
URL: https://github.com/apache/iggy/pull/4381
What Changed
Adds deleteSegments to the Java SDK's partitions clients across all
transports: the async interface and its TCP client (new
CommandCode.Segment.DELETE = 503 payload framed as stream id, topic id,
partition_id LE int, segments_count LE int), the blocking interface, its TCP
delegate (thin wrapper over the async client via FutureUtil.resolve), and the
blocking HTTP client (DELETE
/streams/{id}/topics/{id}/partitions/{id}?segments_count=N). A new
PartitionsClientBaseTest case covers the blocking client end to end.
The HTTP layer needs no changes beyond the client mapping since the server
already exposes the segments-delete route; Fetch and other partition mutation
paths that share this client are untouched.
Closes #4369
Local Execution
Passed
Pre-commit hooks ran
AI Usage
If AI tools were used, please answer:
Which tools? Codex
Scope of usage? Implementation
How did you verify the generated code works correctly? Manual verification,
testing
Can you explain every line of the code if asked? Yes
Want me to fill in the issue numbers?
--
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]
