Code

Fix Kafka offset checking test#1212

Code

Merged

rapids-bot[bot] merged 8 commits intonv-morpheus:branch-23.11nv-morpheus/Morpheus:branch-23.11from dagardner-nv:david-ci-kafka-errorsdagardner-nv/Morpheus:david-ci-kafka-errorsCopy head branch name to clipboardSep 22, 2023

+50-81

Commits

Commits on Sep 21, 2023

• Whitespace change to trigger CI

  dagardner-nv

  committed
  15a7365

• Revert "Whitespace change to trigger CI"

  Show description for 85557dc
  dagardner-nv

  committed
  85557dc

• Declare OffsetChecker as a MRC component so that it executes prior to the source's yield returns.

  Show description for 948f4ef
  dagardner-nv

  committed
  948f4ef

• Revert "Declare OffsetChecker as a MRC component so that it executes prior to the source's yield returns."

  Show description for b3d73ae
  dagardner-nv

  committed
  b3d73ae

Commits on Sep 22, 2023

• Expose seek to beginning logic as a function, create kafka_consumer with a group_id

  dagardner-nv

  committed
  577bd5b

• Move the offset checking from a stage to the test body to be executed after the pipeline completes. The reason is that the C++ impl commits the offsets after calling on_next, this also adds the abi…

  Show description for 3b5d9b9
  dagardner-nv

  committed
  3b5d9b9

• Parametrize on async_commits

  dagardner-nv

  committed
  56332b1

• Merge branch 'branch-23.11' into david-ci-kafka-errors

  dagardner-nv

  authored
  d38caea