Code

feat: add kafka backfill frontend#14465

Code

Closed

xxchan wants to merge 21 commits intomainrisingwavelabs/risingwave:mainfrom 01-02-feat_add_kafka_backfill_frontendrisingwavelabs/risingwave:01-02-feat_add_kafka_backfill_frontendCopy head branch name to clipboard

+2,419-268

Commits

Commits on Mar 1, 2024

• feat(stream): add kafka backill executor

  xxchan

  committed
  420f1ba

• WIP: split change

  xxchan

  committed
  24b4346

• WIP: split change

  xxchan

  committed
  2fee386

• fix lifetime issue

  xxchan

  committed
  041dd0f

• finish split change

  xxchan

  committed
  3d532b5

• rebuild on err & pause/resume

  xxchan

  committed
  70e812d

• fix SourceCachingUp stage

  xxchan

  committed
  14d0919

• minor improvement: avoid compare option string

  xxchan

  committed
  8410696

• fix compilation with new Executor trait

  xxchan

  committed
  22a79c8

• add max_wait_barrier_time_ms

  xxchan

  committed
  580e3ea

• feat: add source backfill metrics

  xxchan

  committed
  ae245a6

• bump buf

  xxchan

  committed
  ef8f3f7

• resolve comments

  xxchan

  committed
  4d62bb2

• give up abort_handles, and use single consumer for all partitions

  xxchan

  committed
  7932c49

Commits on Mar 4, 2024

• Merge branch 'main' into 12-23-feat_stream_add_kafka_backill_executor

  xxchan

  committed
  f2d3a9a

• fix rebuild from error

  xxchan

  committed
  4c27f22

• revert unrelevant change

  xxchan

  committed
  4ccecbb

• remove unrelevant changes (last_row)

  xxchan

  committed
  279026d

Commits on Mar 5, 2024

• Merge remote-tracking branch 'origin/main' into 12-23-feat_stream_add_kafka_backill_executor

  xxchan

  committed
  5f403fd

• feat: add kafka backfill frontend

  xxchan

  committed
  cefa584

• add config for easy of testing

  xxchan

  committed
  8e3c736