tree 169bd8ccc46591685a1d138196a64f593c2532b1
parent 933b09bd64667dc05650b9d999177a64fa088a84
author khenaidoo <knursimu@ciena.com> 1547093192 -0500
committer khenaidoo <knursimu@ciena.com> 1547093564 -0500

This update consists of the following changes:
    1) Add GroupConsumer to the Go sarama_client and modify the Core
    code to use a groupConsumer instead of a partition consumer. This
    change will ensure that multiple consumers (with different group Ids)
    can consume kafka messages from the same topic.
    2) Remove afkak kafka client and replace it with confluent kakfa,
    a change done in voltha 1.x. Modify the code accordingly.
    3) Add a Group Consumer to the Python kakfa client such that
    several instances of an Adapter can consume the same messages from
    the same topic.
    4) Set the datapath_id for the logical device in the Core.

Change-Id: I5d7ced27c9aeca4f6211baa3dc8cb3db861545e4