A Numaflow user-defined source/sink to read/write messages to Kafka topics
active 2024-12-17 → 2026-07-15 (UTC)
Activity over time
Daily event counts in the loaded window
Line chart, 576 days from 2024-12-17 to 2026-07-15. Pushes: 56 total, peak 7 in a day. Pull requests: 12 total, peak 2 in a day. Issues: 20 total, peak 6 in a day. Comments: 25 total, peak 4 in a day. Stars: 2 total, peak 1 in a day.
- Pushes
- Pull requests
- Issues
- Comments
- Stars
Stars, PRs, issues and forks are under-captured in the later part of this window. GH Archive progressively stopped capturing non-push events during 2026 — −95% or worse by the end of the window. Every series here except Pushes fades for that reason, so a decline above reflects the archive, not this repository. Pushes stay reliable throughout, so read them, and the contributor counts derived from them, as the real signal. Data health has the measurements.
Top contributors
Pushes, PRs, issues, reviews and comments — stars and forks excluded, so this is contribution rather than popularity
Recent activity
Latest issues, pull requests and releases
- Issue comment#36KeranYang2026-03-31 17:26refactor: Move away from Springboot
- Issue comment#34cmvs-gh2026-01-24 08:11Using `auto.offset.reset: earliest` causing issues with consumer
- Issue comment#33cmvs-gh2026-01-24 08:11Feature request: support `group.instance.id` using `NUMAFLOW_REPLICA` env var
- Issue comment#34KeranYang2026-01-24 05:42Using `auto.offset.reset: earliest` causing issues with consumer
- Issue comment#33KeranYang2026-01-24 05:37Feature request: support `group.instance.id` using `NUMAFLOW_REPLICA` env var
- Issue#32KeranYang2026-01-12 19:40move away from spring-boot
- Issue#30KeranYang2025-11-29 00:35Support JSON Structured Logging
- Issue comment#31KeranYang2025-11-29 00:35docs: structured logging
- Issue comment#30syepes2025-11-28 22:32Support JSON Structured Logging
- Issue comment#30KeranYang2025-11-28 21:12Support JSON Structured Logging
- Issue comment#27syepes2025-11-27 11:10Consumer config (group id) - IllegalArgumentException
- Pull request#28KeranYang2025-11-26 22:02
- Issue comment#25vigith2025-11-21 19:13chore: upgrade to numaflow-java 0.10.0
- Pull request#25KeranYang2025-11-21 18:57
- Pull request#24KeranYang2025-11-21 16:12
- Pull request#21KeranYang2025-05-19 14:07
- Pull request#21KeranYang2025-05-19 14:00
- Issue#9KeranYang2025-01-16 17:33secret management support
- Pull request#20KeranYang2025-01-16 17:33
- Pull request#20KeranYang2025-01-15 18:40
- Issue#4KeranYang2025-01-14 22:44enable schema id as part of user configuration
- Issue#8KeranYang2025-01-14 22:44json schema support for source and sink
- Pull request#14KeranYang2025-01-14 19:10
- Issue#19KeranYang2025-01-14 02:09support non-JSON output type for Arvo consumer
- Issue#18KeranYang2025-01-13 21:30support non-JSON input type for Arvo producer
Totals cover only the window loaded into ClickHouse and count events, not GitHub's lifetime totals — 2 stars here means stars gained during the window, not the repo's star count.