This is extension of #4624 as discussed in comments. We can optimize the Kafka flow for setups which do not collect logs as part of invocation flow and instead use some sort of LogDriverLogStore
Such setups can send CombinedCompletionAndResultMessage if
job.action.limits.logs.asMegaBytes == 0.MB
- OR
LogDriverLogStore is being used