Code

feat: Kafka EventBus#2502

Code

Merged

whynowy merged 41 commits intoargoproj:masterargoproj/argo-events:masterfrom intuit-data-os:feature/kafka-eventbusintuit-data-os/argo-events:feature/kafka-eventbusCopy head branch name to clipboardMar 23, 2023

+3,693-344

Commits

Commits on Mar 21, 2023

• Initial scaffolding for kafka eventbus

  Show description for c08a009
  dfarr

  committed
  c08a009

• Add kafka eventbus spec (#12)

  Show description for 81fb278
  

  premadk

  authored and

  dfarr

  committed
  81fb278

• in-cluster kafka (#14)

  Show description for 7532cb9
  

  bilalba

  and

  dfarr

  committed
  7532cb9

• Kafka Validations (#16)

  Show description for 9008646
  

  bilalba

  and

  dfarr

  committed
  9008646

• Implement kafka eventbus eventsource (#11)

  Show description for 01197a0
  dfarr

  committed
  01197a0

• Enable kafka functional tests

  Show description for 0308141
  dfarr

  committed
  0308141

• Kafka eventbus sensor (#18)

  Show description for a1b2575
  

  dfarr

  and

  bilalba

  committed
  a1b2575

• Enable sasl support for kafka eventbus

  Show description for 3722a3e
  dfarr

  committed
  3722a3e

• Add offset manager

  Show description for 20cc7bf
  dfarr

  committed
  20cc7bf

• Enable batching

  Show description for 0a67273
  dfarr

  committed
  0a67273

• Add argo-events-sa service account to all e2e tests

  Show description for f0d154a
  dfarr

  committed
  f0d154a

• Consolidate kafka eventbus config

  Show description for 3975699
  dfarr

  committed
  3975699

• Action function need not return an error

  Show description for 785fd2f
  dfarr

  committed
  785fd2f

• Enable condition resets

  Show description for 3820cc3
  dfarr

  committed
  3820cc3

• Change event time check logic

  Show description for 3ed44a0
  dfarr

  committed
  3ed44a0

• Bypass leader election for kafka eventbus sensor

  Show description for 1543eca
  dfarr

  committed
  1543eca

• Guard against batch with no messages

  Show description for 3ac68e0
  dfarr

  committed
  3ac68e0

• Use message timestamp for resets instead of event timestamp

  Show description for b97b80e
  dfarr

  committed
  b97b80e

• Add version to kafka config

  Show description for 71713c4
  dfarr

  committed
  71713c4

• fix version in config (#19)

  Show description for 6297ec4
  

  premadk

  authored and

  dfarr

  committed
  6297ec4

• Remove kafka streamconfig

  Show description for 9bd2fd7
  dfarr

  committed
  9bd2fd7

• Attach access secret for kafka eventbus and sensor

  Show description for ebc7ca7
  dfarr

  committed
  ebc7ca7

• Attach secrets to eventsource and sensor when using kafka eventbus

  Show description for 5f7690c
  dfarr

  committed
  5f7690c

• Remove accessSecret from kafka config and make group name optional

  Show description for 54e5e21
  dfarr

  committed
  54e5e21

• Log when event is filtered out

  Show description for ca80bf6
  dfarr

  committed
  ca80bf6

• Add batch tests

  Show description for a676c26
  dfarr

  committed
  a676c26

• Provide helpful message if topic(s) do not exist and fail fast

  Show description for 61b5cf5
  dfarr

  committed
  61b5cf5

• Add timing asserts to batch tests

  Show description for d6e1b08
  dfarr

  committed
  d6e1b08

• Nullify batch to reset

  Show description for f814685
  dfarr

  committed
  f814685

• Batch every second

  Show description for 4a1d1db
  dfarr

  committed
  4a1d1db

• Revert eventbus controller status copy

  Show description for f945c4e
  dfarr

  committed
  f945c4e

• Update comments

  Show description for 9d92087
  dfarr

  committed
  9d92087

• Revert ci pull_request branches

  Show description for 30e1ad5
  dfarr

  committed
  30e1ad5

• Use dashes ('-') instead of dots ('.') in default kafka names

  Show description for bd7c23f
  dfarr

  committed
  bd7c23f

• Add comments

  Show description for 334e4d1
  dfarr

  committed
  334e4d1

• Move kafka specs to test-functional only

  Show description for cd241b9
  dfarr

  committed
  cd241b9

• Add batch comment

  Show description for 70d879d
  dfarr

  committed
  70d879d

• Remove exotic from kafka eventbus spec

  Show description for 522cfa0
  dfarr

  committed
  522cfa0

• Add additional controller tests for eventsource and sensor

  Show description for f1e79a4
  dfarr

  committed
  f1e79a4

• Add Kafka EventBus docs

  Show description for def91b2
  dfarr

  committed
  def91b2

Commits on Mar 22, 2023

• Remove key from kafka trigger message

  Show description for c7ce51d
  dfarr

  committed
  c7ce51d