Zl/ingestion fixes

[zhilingc]

Fixing some issues that the job consolidation in PR #279 caused.
Main issue was that each subgraph consumed from the same consumer group, which caused issues for jobs involving more than 1 feature set.

To remedy this, in this fix, we only have a single read from source node, and fan out from there.

Original ingestion job:

                 +------------+
                 |            |
               +-+  writeRow  |
 +-----------+ | |            |
 |           | | +------------+
 | readKafka +-+                   
 |           | | +------------+
 +-----------+ | |            |
               +-+ writeError |
                 |            |
                 +------------+
.
.
.
                 +------------+
                 |            |
               +-+  writeRow  |
 +-----------+ | |            |
 |           | | +------------+
 | readKafka +-+                   
 |           | | +------------+
 +-----------+ | |            |
               +-+ writeError |
                 |            |
                 +------------+

where each readKafka node shared a single consumer group

Fix:

                                   +-------------+
                                   |             |
                                +--+  writeRows  |
                 +------------+ |  |             |
                 |            | |  +-------------+
              +--+  validate  +-+
              |  |            | |  +-------------+
              |  +------------+ |  |             |
              |                 +--+ writeErrors |
+-----------+ |                    |             |
|           | |        .           +-------------+
| readKafka +-+        .
|           | |        .           +-------------+
+-----------+ |                    |             |
              |                 +--+  writeRows  |
              |  +------------+ |  |             |
              |  |            | |  +-------------+
              +--+  validate  +-+
                 |            | |  +-------------+
                 +------------+ |  |             |
                                +--+ writeErrors |
                                   |             |
                                   +-------------+

[zhilingc]

/retest

[feast-ci-bot]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: thirteen37, zhilingc

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 [thirteen37,zhilingc]

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

[thirteen37]

/lgtm