Code

feat: add kafka support#56

Code

Merged

brayniac merged 18 commits intoiopsystems:mainiopsystems/rpc-perf:mainfrom yangxi:kafka-clientyangxi/rpc-perf:kafka-clientCopy head branch name to clipboardOct 19, 2023

+677-118

Commits

Commits on Oct 16, 2023

• Add Kafka pubsub

  yangxi

  committed
  2987c80

• cargo fmt

  yangxi

  committed
  1394f75

• Add the kafka file

  yangxi

  committed
  b53dccc

Commits on Oct 17, 2023

• Fix the subscriber (consumer) in the Kafka client

  yangxi

  committed
  55f4f84

• fix errors

  yangxi

  committed
  0d94102

• Add the Kafka config file

  yangxi

  committed
  d4616c6

• merge with main

  yangxi

  committed
  4e1fdb7

Commits on Oct 18, 2023

• Switch the PUBSUB_PUBLISH to use the counter metric

  yangxi

  committed
  1ae3738

• Validate the existing topic

  yangxi

  committed
  6f0f10b

• Add the topic_names config parameter

  yangxi

  committed
  3123dda

• Add kafka specific configurations

  yangxi

  committed
  86df2fd

• Fix some clippies

  yangxi

  committed
  97bf1cd

• Rename MessageValidationResult

  yangxi

  committed
  694c871

• More clippies

  yangxi

  committed
  fb5172d

• Fix minor issue

  yangxi

  committed
  4c3a4f7

Commits on Oct 19, 2023

• More minor fixes

  yangxi

  committed
  f75bb77

• Fix the metric counting issue in request!

  yangxi

  committed
  20db51e

• Minor name fix

  yangxi

  committed
  cf75acc