[Backport 7.75.x] Fix Protobuf with schema registry usage for kafka-actions #22271
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Backport 19bc7d4 from #22265.
What does this PR do?
Kafka actions were migrated to kafka-actions (from kafka_consumer).
However, I merged this fix to kafka_consumer, that I didn't migrate to kafka-actions.
On top of that, there is an edge case (when there is a single message in a protobuf) that I fixed + added a unit test in both kafka_consumer & kafka_actions.
I will remove that logic from kafka_consumer in the near future and only rely on kafka-actions.
Motivation
Moving to kafka-actions for all actions performed on kafka.
Review checklist (to be filled by reviewers)
qa/skip-qalabel if the PR doesn't need to be tested during QA.backport/<branch-name>label to the PR and it will automatically open a backport PR once this one is merged