Code

materialize-kafka: new connector#2196

Code

Open

williamhbaker wants to merge 12 commits intomainestuary/connectors:mainfrom wb/materialize-kafkaestuary/connectors:wb/materialize-kafkaCopy head branch name to clipboard

+5,364

Commits

Commits on Nov 27, 2024

• materialize-kafka: initial working version

  Show description for 653b97a
  williamhbaker

  committed
  653b97a

• materialize-kafka: don't log PartitionEOF at the ERROR level

  Show description for 533ed07
  williamhbaker

  committed
  533ed07

Commits on Dec 9, 2024

• materialize-kafka: option for JSON encoding without schema registry

  Show description for 4ab6df4
  williamhbaker

  committed
  4ab6df4

• materialize-kafka: add snapshot tests

  Show description for d4edbd4
  williamhbaker

  committed
  d4edbd4

• materialize-kafka: add to CI & create integration test

  Show description for 8c98e6c
  williamhbaker

  committed
  8c98e6c

• materialize-kafka: recommend flow_published_at field by default

  Show description for 71c5dd1
  williamhbaker

  committed
  71c5dd1

• materialize-kafka: add more logging for checkpoint recovery

  Show description for 7466f26
  williamhbaker

  committed
  7466f26

Commits on Dec 10, 2024

• materialize-kafka: switch to ThreadedProducer and don't store checkpoints

  Show description for c16d094
  williamhbaker

  committed
  c16d094

Commits on Dec 11, 2024

• materialize-kafka: remove MSK connection option

  Show description for 0d7bb2b
  williamhbaker

  committed
  0d7bb2b

• materialize-kafka: fix pointer for key schema generation

  Show description for b1de2dd
  williamhbaker

  committed
  b1de2dd

• materialize-kafka: fix ci test

  williamhbaker

  committed
  750aa09

• materialize-kafka: update flow protocol pin

  williamhbaker

  committed
  ce25285