gerrit.opencord.org / kafka-onos / eca34fbdcd168667a425d8f4fead070260fac5ad / src / main / java / org / opencord / kafka / integrations / AbstractKafkaIntegration.java