chiradip opened a new issue, #2201: URL: https://github.com/apache/iggy/issues/2201
**Description:** The current Java SDK only provides blocking I/O operations through `IggyTcpClient` and `IggyHttpClient`. This severely limits performance in stream processing frameworks like Apache Flink. **Current State:** ```java // Only blocking operations available PolledMessages messages = client.messages().pollMessages(...); // Blocks thread ``` **Proposed Solution:** ```java // Add async operations CompletableFuture<PolledMessages> future = client.messages().pollMessagesAsync(...); ``` **Impact:** - Multi x performance improvement expected (To be measured) - Essential for External (e.g Flink) connector efficiency - Reduces thread usage from 10-15 to 2-4 per task **Implementation Suggestions:** - Use Netty for non-blocking I/O - Provide CompletableFuture-based API - Maintain backward compatibility with blocking client -- 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]
