Shanicky Chen

feat(kafka): add multiplexed reader support to Kafka source connector

2

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). ## What's changed and what's your intention? WIP State. Because our source reader framework is somewhat...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). This PR attempts to fix the occasional issue of event loss for newly added workers during...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). ## What's changed and what's your intention? Introduce a new configuration and mechanism to specify separate...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). ## What's changed and what's your intention? **Summary** This PR improves the robustness of background DDL...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). ## What's changed and what's your intention? Move the first `ticker.tick().await` after setting up the notification...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). ## What's changed and what's your intention?  **Summary** This PR introduces a new `LinearCurve` variant...

Remove the `assigned_parallelism` field from `StreamJobFragments` and related code to decouple parallelism state from fragment models. Parallelism is now fetched dynamically and passed during protobuf conversion or fragment construction. -...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://raw.githubusercontent.com/risingwavelabs/risingwave/17af8a747593ebdbfa826691daf75bdab7d14fa0/.github/contributor-license-agreement.txt). ## What's changed and what's your intention? **Summary** This PR introduces a new scalar function `rw_adaptive_parallelism(int4)...