Vigith Maurice

Even with `Redelivered Messages: 0`, why are we seeing the difference? https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/consumers#stream-vs-consumer-sequence-numbers ``` Configuration: Name: oss-analytics-xxx-usw2-prd-fci-blackhole-pipeline-2-blackhole-sink-1 Pull Mode: true Filter Subject: oss-analytics-xxx-usw2-prd-fci-blackhole-pipeline-2-blackhole-sink-1 Deliver Policy: All Ack Policy: Explicit Ack Wait:...

**Describe the bug** Unprocessed == 0 while Stream seq in the stream metadata is moving ahead of the consumer seq number. ### Consumer Metadata ``` Last Delivered Message: Consumer sequence:...

# Summary - [ ] update version compatibility matrix - [ ] release all SDKs - [ ] enable `WorkQueue` policy on JetStream - [ ] endurance test - [...

There will be other extensions that will be written in Rust, so we should make the top level dir `ext` and serving be a workspace member.

# Summary We need to build a serving layer (supporting HTTP 1 and 2) on top of the Numaflow engine to support both sync/async endpoints. The serving layer can also...

**Describe the bug** watermark updates get linearly slow with an increase in partition count, causing `forward-a-chunk` to block. we noticed this issue when reading from Kafka with partition counts ~...

# Summary ISBs should auto-heal and send alerts and events - [ ] auto-balancing of streams - [ ] scripts to recreate a irrecoverable or bad ISB - [ ]...

# Summary Show the source partition watermark in the UI so it is easy to know which partition is causing the lag # Use Cases While debugging --- **Message from...

# Summary Today, users are not aware of what a Numaflow pipeline is or the different types of vertices, and how they are integrated. The best way to introduce Numaflow...