gerrit.opencord.org / kafka-onos / 8a015836e9f021a4dda38c5deea3c4cb61f3ab5c / src / main / java / org / opencord / kafka / integrations / DeviceKafkaIntegration.java