gerrit.opencord.org / kafka-onos / 036c7942a6def5b6e2735bdb9a435cc625ecb9a7 / src / main / java / org / opencord / kafka / integrations / McastKafkaIntegration.java