numaflow-java
numaflow-java copied to clipboard
numaproj
Numaflow Java SDK
Currently, only @yhl25 knows how to configure and I think it's also configured using his account.
https://github.com/numaproj/numaflow-java/actions/runs/8469748515/job/23205796860 - map-forward-message The session reduce ServerTest failed because of receiving an AKKA dead letter. To reproduce - run open_expand_close unit test until failure. One observation is that if I...
[Spring Boot](https://spring.io/projects/spring-boot) is widely used in the Java community to inject dependencies. It would be great if we have an example showing how to use it in the numaflow world....
We need to run the session window SDK on a real pipeline and verify it's working properly with all the operations, especially EXPAND and MERG.
Instead of writing manually, use protoc to generate code from proto files.
As a numaflow java sdk developer, I want to be able to run a performance test job against my changes and quickly identify if my changes downgrade or upgrade the...
I have a numaflow v0.10.1 pipeline with a reduce vertex numaflow-java 0.5.5. I am using keyed messages with size one and 2 partitions. After several messages entering the group node...
Benefits include: 1. Loose coupling 2. Modularity 3. Easy to test 4. Reusability 5. Separation of concerns etc. Eventually leads to more modular, maintainable, and testable code. There are several...