Code

MySQL CDC Plugin#3014

Code

Open

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

+2,259-4

Commits

Commits on Jan 12, 2025

• feat(mysql_cdc): working on mysql_cdc plugin

  

  le-vlad

  authored and

  mihaitodor

  committed
  76ef366

  Copy full SHA for 76ef366

• chore(): continue working on mysql cdc

  

  le-vlad

  authored and

  mihaitodor

  committed
  19dab6e

  Copy full SHA for 19dab6e

• chore(): removed in test secret

  

  le-vlad

  authored and

  mihaitodor

  committed
  29c950f

  Copy full SHA for 29c950f

• chore(): working on mysql cdc

  

  le-vlad

  authored and

  mihaitodor

  committed
  3391a64

  Copy full SHA for 3391a64

• chore(): added mysql tests

  

  le-vlad

  authored and

  mihaitodor

  committed
  b0747e2

  Copy full SHA for b0747e2

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

  

  le-vlad

  authored and

  mihaitodor

  committed
  77fbcc2

  Copy full SHA for 77fbcc2

• chore(): implemented snapshot support

  

  le-vlad

  authored and

  mihaitodor

  committed
  2e9b57c

  Copy full SHA for 2e9b57c

• chore(): reset dumper config

  

  le-vlad

  authored and

  mihaitodor

  committed
  901b4fe

  Copy full SHA for 901b4fe

• fix(): table filtering for mysql

  

  le-vlad

  authored and

  mihaitodor

  committed
  f275aa7

  Copy full SHA for f275aa7

• fix(): golangci-lint

  

  le-vlad

  authored and

  mihaitodor

  committed
  1927dbe

  Copy full SHA for 1927dbe

• chore(): added table validation

  

  le-vlad

  authored and

  mihaitodor

  committed
  f074e50

  Copy full SHA for f074e50

• fix(): lint

  

  le-vlad

  authored and

  mihaitodor

  committed
  882c8d1

  Copy full SHA for 882c8d1

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

  

  le-vlad

  authored and

  mihaitodor

  committed
  86238d5

  Copy full SHA for 86238d5

• chore(): work on pr notes

  

  le-vlad

  authored and

  mihaitodor

  committed
  dadabe0

  Copy full SHA for dadabe0

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

  

  le-vlad

  authored and

  mihaitodor

  committed
  193c574

  Copy full SHA for 193c574

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

  

  le-vlad

  authored and

  mihaitodor

  committed
  8a8eb8b

  Copy full SHA for 8a8eb8b

• mysqlcdc: rename component

  

  rockwotj

  authored and

  mihaitodor

  committed
  2373dee

  Copy full SHA for 2373dee

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

  

  rockwotj

  authored and

  mihaitodor

  committed
  166f1dc

  Copy full SHA for 166f1dc

• snapshot: cleanup context usage

  Show description for 6643ea4
  

  rockwotj

  authored and

  mihaitodor

  committed
  6643ea4

  Copy full SHA for 6643ea4

• mysql: fold mode into operation

  Show description for 78af575
  

  rockwotj

  authored and

  mihaitodor

  committed
  78af575

  Copy full SHA for 78af575

• mysql: fix ack fn

  

  rockwotj

  authored and

  mihaitodor

  committed
  786480c

  Copy full SHA for 786480c

• mysql: use error return type

  

  rockwotj

  authored and

  mihaitodor

  committed
  eead6dc

  Copy full SHA for eead6dc

• mysql: simplify constructor

  

  rockwotj

  authored and

  mihaitodor

  committed
  7498891

  Copy full SHA for 7498891

• mysql: cleaner import name

  

  rockwotj

  authored and

  mihaitodor

  committed
  3b3998d

  Copy full SHA for 3b3998d

• mysql: escape table regex

  

  rockwotj

  authored and

  mihaitodor

  committed
  586b387

  Copy full SHA for 586b387

• mysql: simplify checkpointer

  

  rockwotj

  authored and

  mihaitodor

  committed
  c5328df

  Copy full SHA for c5328df

• mycdc: use lexicographically ordered binlog position

  

  rockwotj

  authored and

  mihaitodor

  committed
  b5fad95

  Copy full SHA for b5fad95

• mycdc: draw the rest of the owl

  Show description for 5555c92
  

  rockwotj

  authored and

  mihaitodor

  committed
  5555c92

  Copy full SHA for 5555c92

• mycdc: make the linter happy

  

  rockwotj

  authored and

  mihaitodor

  committed
  dbbad4a

  Copy full SHA for dbbad4a

• mycdc: cleanup integration tests

  

  rockwotj

  authored and

  mihaitodor

  committed
  63c320e

  Copy full SHA for 63c320e

• mycdc: decode stream message by type

  Show description for b06d218
  

  rockwotj

  authored and

  mihaitodor

  committed
  b06d218

  Copy full SHA for b06d218

• mycdc: add more types

  

  rockwotj

  authored and

  mihaitodor

  committed
  8ede4a6

  Copy full SHA for 8ede4a6

• mycdc: fix snapshot cleanup and missing pks

  

  rockwotj

  authored and

  mihaitodor

  committed
  b0f8ea7

  Copy full SHA for b0f8ea7

• mycdc: fix shutdown hang

  

  rockwotj

  authored and

  mihaitodor

  committed
  30148d0

  Copy full SHA for 30148d0

• mycdc: fix snapshot types

  

  rockwotj

  authored and

  mihaitodor

  committed
  243eee5

  Copy full SHA for 243eee5

• mycdc: handle all types 🎉

  

  rockwotj

  authored and

  mihaitodor

  committed
  87986f8

  Copy full SHA for 87986f8

• mycdc: cleanup tests for MySQL CDC

  

  rockwotj

  authored and

  mihaitodor

  committed
  0f6efb5

  Copy full SHA for 0f6efb5

• mycdc: handle nil streaming values

  

  rockwotj

  authored and

  mihaitodor

  committed
  a2dd9ca

  Copy full SHA for a2dd9ca

• add changelog entry

  

  rockwotj

  authored and

  mihaitodor

  committed
  f34111c

  Copy full SHA for f34111c

• make linter happy

  

  rockwotj

  authored and

  mihaitodor

  committed
  e118968

  Copy full SHA for e118968

• mycdc: add comment about txn

  

  rockwotj

  authored and

  mihaitodor

  committed
  e3d2b7d

  Copy full SHA for e3d2b7d

• Fix some nitpicks

  Show description for a873c23
  mihaitodor

  committed
  a873c23

  Copy full SHA for a873c23

• Add to public components and generate docs

  Show description for a144500
  mihaitodor

  committed
  a144500

  Copy full SHA for a144500

• Re-enable the rowserrcheck linter

  Show description for 673f51a
  mihaitodor

  committed
  673f51a

  Copy full SHA for 673f51a