[POLICY-SDC-DIST] Upgrade policy-distribtuion to use kafka native