NETOBSERV-984 - KafkaInterBrokerProtocalVersion throws warning and has ingestion errors

[jpinsonneau]

Rely on TimeFlowEndMs for kafka delay as the Decode function returns a GenericMap that doesn't contains TimeFlowEnd.

Related PRs:
https://github.com/netobserv/flowlogs-pipeline/pull/203/files
https://github.com/netobserv/network-observability-console-plugin/pull/153/files

[github-actions]

New image: quay.io/netobserv/flowlogs-pipeline:bf793ba. It will expire after two weeks.

[codecov]

Codecov Report

Merging #428 (812a7fa) into main (4aee357) will decrease coverage by 0.03%.
The diff coverage is 33.33%.

@@            Coverage Diff             @@
##             main     #428      +/-   ##
==========================================
- Coverage   64.72%   64.70%   -0.03%     
==========================================
  Files          94       94              
  Lines        6645     6649       +4     
==========================================
+ Hits         4301     4302       +1     
- Misses       2100     2103       +3     
  Partials      244      244              

Flag	Coverage Δ
unittests	64.70% <33.33%> (-0.03%)	⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
pkg/pipeline/decode/decode_protobuf.go	76.00% <0.00%> (-1.56%)	⬇️
pkg/pipeline/ingest/ingest_grpc.go	75.00% <0.00%> (-1.06%)	⬇️
pkg/pipeline/ingest/ingest_kafka.go	65.38% <42.85%> (-0.18%)	⬇️

[OlivierCazade]

LGTM

[nathan-weinberg]

@jpinsonneau @OlivierCazade i can test this on a fresh cluster tmrw, let me know if you seen any issues with the fix on the Baremetal cluster

[nathan-weinberg]

/label qe-approved

[jpinsonneau]

/approve

[openshift-ci]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: jpinsonneau

The full list of commands accepted by this bot can be found here.

The pull request process is described here

Needs approval from an approver in each of these files:

• OWNERS [jpinsonneau]

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment