gerrit.onosproject.org / onos / a4875d829305cfbfac6c741504b3d02d17a4ea29 / apps / kafka-integration / core / src / main / java / org / onosproject / kafkaintegration / kafka / PublishManager.java