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