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