Code

feat: add global consume timeout#1061

Code

Open

bojan-rajkovic-simplisafe wants to merge 9 commits intoBlizzard:masterBlizzard/node-rdkafka:masterfrom bojan-rajkovic-simplisafe:brajkovic/feat/add-global-consume-timeoutbojan-rajkovic-simplisafe/node-rdkafka:brajkovic/feat/add-global-consume-timeoutCopy head branch name to clipboard

+194-52

Commits

Commits on Dec 6, 2023

• workers: add ability to set a total consume operation timeout to the consumenum worker

  Show description for 3938300
  bojan-rajkovic-simplisafe

  committed
  3938300

  Copy full SHA for 3938300

• consumer: implement new total consume operation timeout argument in c++-land

  Show description for 79b4bdc
  bojan-rajkovic-simplisafe

  committed
  79b4bdc

  Copy full SHA for 79b4bdc

• consumer: thread through total consume timeout to js-land

  Show description for 3d9f365
  bojan-rajkovic-simplisafe

  committed
  3d9f365

  Copy full SHA for 3d9f365

• test: add new tests for the global consume timeout set and unset variants

  bojan-rajkovic-simplisafe

  committed
  984cd88

  Copy full SHA for 984cd88

• types: fix consume(cb) type definition to make it clear it'll flow a single message

  bojan-rajkovic-simplisafe

  committed
  202305c

  Copy full SHA for 202305c

Commits on Dec 7, 2023

• tests: fix a few typos and wrong assertions

  bojan-rajkovic-simplisafe

  committed
  7c66aa9

  Copy full SHA for 7c66aa9

• fix: properly pass total timeout to c++land

  bojan-rajkovic-simplisafe

  committed
  6d4602e

  Copy full SHA for 6d4602e

• refactor: cleanu up some dead code in c++, fix consumeloop argument checks

  bojan-rajkovic-simplisafe

  committed
  f37dfa6

  Copy full SHA for f37dfa6

• tests: fix assertion for partial batch timing

  bojan-rajkovic-simplisafe

  committed
  d9c3d3b

  Copy full SHA for d9c3d3b