Code

MySQL CDC Plugin#3014

Code

Open

le-vlad wants to merge 40 commits intoredpanda-data:mainredpanda-data/connect:mainfrom le-vlad:mysql_cdcle-vlad/connect:mysql_cdcCopy head branch name to clipboard

+1,932-4

Commits

Commits on Dec 20, 2024

• feat(mysql_cdc): working on mysql_cdc plugin

  

  le-vlad

  authored and

  rockwotj

  committed
  04d1081

• chore(): continue working on mysql cdc

  

  le-vlad

  authored and

  rockwotj

  committed
  51ee05a

• chore(): removed in test secret

  

  le-vlad

  authored and

  rockwotj

  committed
  25269ba

• chore(): working on mysql cdc

  

  le-vlad

  authored and

  rockwotj

  committed
  60224a8

• chore(): added mysql tests

  

  le-vlad

  authored and

  rockwotj

  committed
  d8090ea

• chore(): multi-version testing for mysql cdc

  

  le-vlad

  authored and

  rockwotj

  committed
  a20567b

• chore(): implemented snapshot support

  

  le-vlad

  authored and

  rockwotj

  committed
  ad04693

• chore(): reset dumper config

  

  le-vlad

  authored and

  rockwotj

  committed
  415ca77

• fix(): table filtering for mysql

  

  le-vlad

  authored and

  rockwotj

  committed
  eb1759a

• fix(): golangci-lint

  

  le-vlad

  authored and

  rockwotj

  committed
  7e8c3ee

• chore(): added table validation

  

  le-vlad

  authored and

  rockwotj

  committed
  d349ddd

• fix(): lint

  

  le-vlad

  authored and

  rockwotj

  committed
  f0b5f6c

• fix(): added integration.CheckSkip(t) to mysql cdc tests

  

  le-vlad

  authored and

  rockwotj

  committed
  5a41ea4

• chore(): work on pr notes

  

  le-vlad

  authored and

  rockwotj

  committed
  1a292f0

• chore(): updated comments and use ctx from shutdown

  

  le-vlad

  authored and

  rockwotj

  committed
  46c9836

• chore(): removed rows count && small pr notes

  

  le-vlad

  authored and

  rockwotj

  committed
  e3b4a60

• mysqlcdc: rename component

  rockwotj

  committed
  f832412

• mysql: seperate cache key vs cache that is used in configs

  rockwotj

  committed
  a1decce

• snapshot: cleanup context usage

  Show description for 5dc2fd0
  rockwotj

  committed
  5dc2fd0

• mysql: fold mode into operation

  Show description for 69a1c4a
  rockwotj

  committed
  69a1c4a

• mysql: fix ack fn

  rockwotj

  committed
  340abdd

• mysql: use error return type

  rockwotj

  committed
  36dc9d2

• mysql: simplify constructor

  rockwotj

  committed
  1dda403

• mysql: cleaner import name

  rockwotj

  committed
  99783b4

• mysql: escape table regex

  rockwotj

  committed
  d5490ef

• mysql: simplify checkpointer

  rockwotj

  committed
  8e0d939

• mycdc: use lexicographically ordered binlog position

  rockwotj

  committed
  976581e

• mycdc: draw the rest of the owl

  Show description for 7011f46
  rockwotj

  committed
  7011f46

• mycdc: make the linter happy

  rockwotj

  committed
  1224e61

• mycdc: cleanup integration tests

  rockwotj

  committed
  dc6af1d

• mycdc: decode stream message by type

  Show description for a39840f
  rockwotj

  committed
  a39840f

• mycdc: add more types

  rockwotj

  committed
  807f450

• mycdc: fix snapshot cleanup and missing pks

  rockwotj

  committed
  f66925c

• mycdc: fix shutdown hang

  rockwotj

  committed
  05d16ab

• mycdc: fix snapshot types

  rockwotj

  committed
  0df6ae0

• mycdc: handle all types 🎉

  rockwotj

  committed
  839ee14

• mycdc: cleanup tests for MySQL CDC

  rockwotj

  committed
  ebc752a

• mycdc: handle nil streaming values

  rockwotj

  committed
  43adf68

• add changelog entry

  rockwotj

  committed
  8834980

• make linter happy

  rockwotj

  committed
  80ef106