Code

kafka + lua scripting + flatbuffers#1461

Code

Merged

serprex merged 31 commits intomainPeerDB-io/peerdb:mainfrom redpandaPeerDB-io/peerdb:redpandaCopy head branch name to clipboardMar 21, 2024

+1,462-103

Commits

Commits on Mar 21, 2024

• Yet another kafka connector

  Show description for 5d7d15a
  serprex

  committed
  5d7d15a

• cleanup UI, add missing parts

  

  Amogh-Bharadwaj

  authored and

  serprex

  committed
  6b6a8f9

• Add script to ui, script is name, rely on loader to retrieve from catalog

  Show description for 046ec57
  serprex

  committed
  046ec57

• replace big.Rat with decimal.Decimal, add more __tostring

  serprex

  committed
  a282e61

• Fix CreateByteVector, expose more decimal/int properties

  serprex

  committed
  1c6376a

• add peerdb.type function to help with debugging

  serprex

  committed
  f3c957b

• Don't expose QValue directly to scripts

  Show description for 3e90271
  serprex

  committed
  3e90271

• 3 tweaks:

  Show description for 6107a89
  serprex

  committed
  6107a89

• fix resize not updating data

  serprex

  committed
  9ef43f2

• Fix flatbuffers not handling buffer resizing properly

  serprex

  committed
  2d66ed1

• Kafka: username optional, if not supplied no auth used

  serprex

  committed
  8f97c68

• Move flatbuffers into its own package, fix stack not being cleared in kafka code

  serprex

  committed
  0c97fca

• lua: bit32

  serprex

  committed
  93c5ccb

• Remove FlatBuffer_ prefixes

  serprex

  committed
  b4b57b6

• adjust arrays to 1 based offset when row value is an array being converted to table

  serprex

  committed
  3b2e236

• Add lo/hi properties to i64/u64 types to help use with bit32 library

  serprex

  committed
  9ec1c58

• onRecord: support for multiple returns

  Show description for 163a1e2
  serprex

  committed
  163a1e2

• flatbuffers: license directory as ApacheV2 & add readme explaining

  serprex

  committed
  5554b51

• Rename LuaUserDataType to UserDataType

  serprex

  committed
  188a30d

• add some basic unit testing to pua, fix i64/u64 comparisons

  serprex

  committed
  f5c1668

• first stab at a basic kafka e2e test

  serprex

  committed
  820cd23

• add CommitTime to cdc messages, expose to script

  serprex

  committed
  00d40d4

• Add Script to mirror details in UI

  serprex

  committed
  876a79e

• reduce BaseMessage size by 16 bytes only storing unix nano, good until year 2262

  serprex

  committed
  53028df

• clippy

  serprex

  committed
  521d576

• moved code to gluaflatbuffers / glua64

  serprex

  committed
  6bd45b3

• kafka: split up SyncRecords, report numrecords as records consumed, not produced

  serprex

  committed
  49200e5

• loadScript cleanup control flow

  serprex

  committed
  cb96820

• move glua64 tests to glua64

  serprex

  committed
  3282859

• fix lint

  serprex

  committed
  19314c0

• oops

  serprex

  committed
  0a81ade