diff --git a/platform/mellanox/docker-syncd-mlnx.mk b/platform/mellanox/docker-syncd-mlnx.mk
index b46c6478cf..db582e517b 100644
--- a/platform/mellanox/docker-syncd-mlnx.mk
+++ b/platform/mellanox/docker-syncd-mlnx.mk
@@ -4,7 +4,6 @@ DOCKER_SYNCD_PLATFORM_CODE = mlnx
 include $(PLATFORM_PATH)/../template/docker-syncd-base.mk
 
 $(DOCKER_SYNCD_BASE)_DEPENDS += $(SYNCD) $(PYTHON_SDK_API)
-$(DOCKER_SYNCD_BASE)_PYTHON_DEBS += $(MLNX_SFPD)
 
 $(DOCKER_SYNCD_BASE)_DBG_DEPENDS += $(SYNCD_DBG) \
                                 $(LIBSWSSCOMMON_DBG) \
diff --git a/platform/mellanox/docker-syncd-mlnx/start.sh b/platform/mellanox/docker-syncd-mlnx/start.sh
index 61ccd2db89..96e2a91280 100755
--- a/platform/mellanox/docker-syncd-mlnx/start.sh
+++ b/platform/mellanox/docker-syncd-mlnx/start.sh
@@ -6,5 +6,3 @@ supervisorctl start rsyslogd
 
 supervisorctl start syncd
 
-supervisorctl start mlnx-sfpd
-
diff --git a/platform/mellanox/docker-syncd-mlnx/supervisord.conf b/platform/mellanox/docker-syncd-mlnx/supervisord.conf
index 8860bd6c02..1af5d70a1d 100644
--- a/platform/mellanox/docker-syncd-mlnx/supervisord.conf
+++ b/platform/mellanox/docker-syncd-mlnx/supervisord.conf
@@ -26,11 +26,3 @@ autostart=false
 autorestart=false
 stdout_logfile=syslog
 stderr_logfile=syslog
-
-[program:mlnx-sfpd]
-command=/usr/bin/mlnx-sfpd
-priority=4
-autostart=false
-autorestart=false
-stdout_logfile=syslog
-stderr_logfile=syslog
diff --git a/platform/mellanox/mlnx-sfpd.mk b/platform/mellanox/mlnx-sfpd.mk
deleted file mode 100644
index 416dd7d0f2..0000000000
--- a/platform/mellanox/mlnx-sfpd.mk
+++ /dev/null
@@ -1,5 +0,0 @@
-# mlnx-sfpd (SONiC MLNX platform sfp event monitoring daemon) Debian package
-
-MLNX_SFPD = python-mlnx-sfpd_1.0-1_all.deb
-$(MLNX_SFPD)_SRC_PATH = $(PLATFORM_PATH)/mlnx-sfpd
-SONIC_PYTHON_STDEB_DEBS += $(MLNX_SFPD)
diff --git a/platform/mellanox/mlnx-sfpd/scripts/mlnx-sfpd b/platform/mellanox/mlnx-sfpd/scripts/mlnx-sfpd
deleted file mode 100644
index b11403b315..0000000000
--- a/platform/mellanox/mlnx-sfpd/scripts/mlnx-sfpd
+++ /dev/null
@@ -1,305 +0,0 @@
-#!/usr/bin/env python
-'''
-This code is for a mlnx platform specific daemon, mlnx-sfpd.
-Which listen to the SDK for the SFP change event and post the event to DB.
-'''
-
-from __future__ import print_function
-import sys, errno
-import os
-import time
-import syslog
-import signal
-import select
-import json
-import threading
-from python_sdk_api.sx_api import *
-from swsssdk import SonicV2Connector
-
-VERSION = '1.0'
-
-SYSLOG_IDENTIFIER = "mlnx-sfpd"
-
-REDIS_HOSTIP = "127.0.0.1"
-
-SDK_SFP_STATE_IN = 0x1
-SDK_SFP_STATE_OUT = 0x2
-STATUS_PLUGIN = '1'
-STATUS_PLUGOUT = '0'
-STATUS_UNKNOWN = '2'
-
-SFPD_LIVENESS_EXPIRE_SECS = 30
-
-SDK_DAEMON_READY_FILE = '/tmp/sdk_ready'
-
-sfp_value_status_dict = {
-        SDK_SFP_STATE_IN:  STATUS_PLUGIN,
-        SDK_SFP_STATE_OUT: STATUS_PLUGOUT,
-}
-
-# ========================== Syslog wrappers ==========================
-def log_info(msg, also_print_to_console=False):
-    syslog.openlog(SYSLOG_IDENTIFIER)
-    syslog.syslog(syslog.LOG_INFO, msg)
-    syslog.closelog()
-
-    if also_print_to_console:
-        print(msg)
-
-def log_warning(msg, also_print_to_console=False):
-    syslog.openlog(SYSLOG_IDENTIFIER)
-    syslog.syslog(syslog.LOG_WARNING, msg)
-    syslog.closelog()
-
-    if also_print_to_console:
-        print(msg)
-
-def log_error(msg, also_print_to_console=False):
-    syslog.openlog(SYSLOG_IDENTIFIER)
-    syslog.syslog(syslog.LOG_ERR, msg)
-    syslog.closelog()
-
-    if also_print_to_console:
-        print(msg)
-
-# ========================== MlnxSfpd class ==========================
-class MlnxSfpd:
-    ''' Listen to plugin/plugout cable events '''
-
-    SX_OPEN_RETRIES = 30
-    SX_OPEN_TIMEOUT = 5
-    SELECT_TIMEOUT = 1
-
-    def __init__(self):
-        self.swid = 0
-        self.running = False
-        self.handle = None
-
-        # Allocate SDK fd and user channel structures
-        self.rx_fd_p = new_sx_fd_t_p()
-        self.user_channel_p = new_sx_user_channel_t_p()
-        self.state_db = SonicV2Connector(host=REDIS_HOSTIP)
-
-        # Register our signal handlers
-        signal.signal(signal.SIGHUP, self.signal_handler)
-        signal.signal(signal.SIGINT, self.signal_handler)
-        signal.signal(signal.SIGTERM, self.signal_handler)
-
-    def signal_handler(self, signum, frame):
-        if signum == signal.SIGHUP:
-            log_info("Caught SIGHUP - ignoring...")
-        elif signum == signal.SIGINT:
-            log_info("Caught SIGINT - exiting...")
-            self.running = False
-        elif signum == signal.SIGTERM:
-            log_info("Caught SIGINT - exiting...")
-            self.running = False
-        else:
-            log_warning("Caught unhandled signal '{}'".format(signum))
-
-    def initialize(self):
-        self.state_db.connect("STATE_DB")
-
-        swid_cnt_p = None
-
-        try:
-            # Wait for SDK daemon to be started with detect the sdk_ready file
-            retry = 0
-            while not os.path.exists(SDK_DAEMON_READY_FILE):  
-                if retry >= self.SX_OPEN_RETRIES:
-                    raise RuntimeError("SDK daemon failed to start after {} retries and {} seconds waiting, exiting..."
-                        .format(retry, self.SX_OPEN_TIMEOUT * self.SX_OPEN_RETRIES))
-                else:
-                    log_info("SDK daemon not started yet, retry {} times".format(retry))
-                    retry = retry + 1
-                    time.sleep(self.SX_OPEN_TIMEOUT)
-
-            # to make sure SDK daemon has started
-            time.sleep(self.SX_OPEN_TIMEOUT)
-
-            # After SDK daemon started, sx_api_open and sx_api_host_ifc_open is ready for call
-            rc, self.handle = sx_api_open(None)
-            if rc != SX_STATUS_SUCCESS:
-                raise RuntimeError("failed to call sx_api_open with rc {}, exiting...".format(rc))
-
-            rc = sx_api_host_ifc_open(self.handle, self.rx_fd_p)
-            if rc != SX_STATUS_SUCCESS:
-                raise RuntimeError("failed to call sx_api_host_ifc_open with rc {}, exiting...".format(rc))
-
-            self.user_channel_p.type = SX_USER_CHANNEL_TYPE_FD
-            self.user_channel_p.channel.fd = self.rx_fd_p
-
-            # Wait for switch to be created and initialized inside SDK
-            retry = 0
-            swid_cnt_p = new_uint32_t_p()
-            uint32_t_p_assign(swid_cnt_p, 0)
-            swid_cnt = 0
-            while True:
-                if retry >= self.SX_OPEN_RETRIES:
-                    raise RuntimeError("switch not created after {} retries and {} seconds waiting, exiting..."
-                        .format(retry, self.SX_OPEN_RETRIES * self.SX_OPEN_TIMEOUT))
-                else:
-                    rc = sx_api_port_swid_list_get(self.handle, None, swid_cnt_p)
-                    if rc == SX_STATUS_SUCCESS:
-                        swid_cnt = uint32_t_p_value(swid_cnt_p)
-                        if swid_cnt > 0:
-                            delete_uint32_t_p(swid_cnt_p)
-                            swid_cnt_p = None
-                            break
-                        else:
-                            log_info("switch not created yet, swid_cnt {}, retry {} times and wait for {} seconds"
-                                .format(swid_cnt, retry, self.SX_OPEN_TIMEOUT * retry))
-                    else:
-                        raise RuntimeError("sx_api_port_swid_list_get fail with rc {}, retry {} times and wait for {} seconds".
-                            format(rc, retry, self.SX_OPEN_TIMEOUT * retry))
-
-                    retry = retry + 1
-                    time.sleep(self.SX_OPEN_TIMEOUT)
-
-            # After switch was created inside SDK, sx_api_host_ifc_trap_id_register_set is ready to call
-            rc = sx_api_host_ifc_trap_id_register_set(self.handle,
-                                                    SX_ACCESS_CMD_REGISTER,
-                                                    self.swid,
-                                                    SX_TRAP_ID_PMPE,
-                                                    self.user_channel_p)
-
-            if rc != SX_STATUS_SUCCESS:
-                raise RuntimeError("sx_api_host_ifc_trap_id_register_set failed with rc {}, exiting...".format(rc))
-
-            self.running = True
-        except Exception as e:
-            log_error("mlnx-sfpd initialization failed due to {}, exiting...".format(repr(e)))
-            if swid_cnt_p is not None:
-                delete_uint32_t_p(swid_cnt_p)
-            self.deinitialize()
-
-    def deinitialize(self):
-        # remove mlnx-sfpd liveness key in DB if not expired yet
-        if self.state_db.exists("STATE_DB", "MLNX_SFPD_TASK|LIVENESS"):
-            self.state_db.delete("STATE_DB", "MLNX_SFPD_TASK|LIVENESS")
-
-        if self.handle is None:
-            return
-
-        # unregister trap id
-        rc = sx_api_host_ifc_trap_id_register_set(self.handle,
-                                                  SX_ACCESS_CMD_DEREGISTER,
-                                                  self.swid,
-                                                  SX_TRAP_ID_PMPE,
-                                                  self.user_channel_p)
-        if rc != SX_STATUS_SUCCESS:
-            log_error("sx_api_host_ifc_trap_id_register_set exited with error, rc {}".format(rc))
-
-        rc = sx_api_host_ifc_close(self.handle, self.rx_fd_p)
-        if rc != SX_STATUS_SUCCESS:
-            log_error("sx_api_host_ifc_close exited with error, rc {}".format(rc))
-
-        rc = sx_api_close(self.handle)
-        if rc != SX_STATUS_SUCCESS:
-            log_error("sx_api_close exited with error, rc {}".format(rc))
-
-    def run(self):
-
-        while self.running:
-            try:
-                read, _, _ = select.select([self.rx_fd_p.fd], [], [], self.SELECT_TIMEOUT)
-            except select.error as err:
-                rc, msg = err
-                if rc == errno.EAGAIN or rc == errno.EINTR:
-                    continue
-                else:
-                    raise
-
-            for fd in read:
-                if fd == self.rx_fd_p.fd:
-                    success, port_list, module_state = self.on_pmpe(self.rx_fd_p)
-                    if not success:
-                        raise RuntimeError("failed to read from {}".format(fd))
-
-                    sfp_state = sfp_value_status_dict.get(module_state, STATUS_UNKNOWN)
-                    if sfp_state == STATUS_UNKNOWN:
-                        log_error("unknown module state {} on port {}".format(module_state, port))
-                        continue
-
-                    for port in port_list:
-                        log_info("SFP on port {} state {}".format(port, sfp_state))
-                        self.send_sfp_notification(str(port), sfp_state)
-
-            self.update_sfpd_liveness_key(SFPD_LIVENESS_EXPIRE_SECS)
-
-    def send_sfp_notification(self, port, state):
-        sfp_notify = [port, state]
-        msg = json.dumps(sfp_notify, separators=(',', ':'))
-        self.state_db.publish('STATE_DB', 'TRANSCEIVER_NOTIFY', msg)
-
-    def update_sfpd_liveness_key(self, timeout_secs):
-        if not self.state_db.exists('STATE_DB', 'MLNX_SFPD_TASK|LIVENESS'):
-            self.state_db.set('STATE_DB', 'MLNX_SFPD_TASK|LIVENESS', 'value', 'ok')
-        self.state_db.expire('STATE_DB', 'MLNX_SFPD_TASK|LIVENESS', timeout_secs)
-
-    def on_pmpe(self, fd_p):
-        ''' on port module plug event handler '''
-
-        # recv parameters
-        pkt_size = 2000
-        pkt_size_p = new_uint32_t_p()
-        uint32_t_p_assign(pkt_size_p, pkt_size)
-        pkt = new_uint8_t_arr(pkt_size)
-        recv_info_p = new_sx_receive_info_t_p()
-        pmpe_t = sx_event_pmpe_t()
-        port_attributes_list = new_sx_port_attributes_t_arr(64)
-        port_cnt_p = new_uint32_t_p()
-        uint32_t_p_assign(port_cnt_p,64)
-        label_port_list = []
-        module_state = 0
-
-        rc = sx_lib_host_ifc_recv(fd_p, pkt, pkt_size_p, recv_info_p)
-        if rc != 0:
-            log_error("sx_lib_host_ifc_recv exited with error, rc %d" % rc)
-            status = False
-        else:
-            status = True
-            pmpe_t = recv_info_p.event_info.pmpe
-            port_list_size = pmpe_t.list_size
-            logical_port_list = pmpe_t.log_port_list
-            module_state = pmpe_t.module_state
-
-            for i in xrange(port_list_size):
-                logical_port = sx_port_log_id_t_arr_getitem(logical_port_list, i)
-                rc = sx_api_port_device_get(self.handle, 1 , 0, port_attributes_list,  port_cnt_p)
-                port_cnt = uint32_t_p_value(port_cnt_p)
-
-                for i in xrange(port_cnt):
-                    port_attributes = sx_port_attributes_t_arr_getitem(port_attributes_list,i)
-                    if port_attributes.log_port == logical_port:
-                        lable_port = port_attributes.port_mapping.module_port
-                        break
-                label_port_list.append(lable_port)
-
-        delete_uint32_t_p(pkt_size_p)
-        delete_uint8_t_arr(pkt)
-        delete_sx_receive_info_t_p(recv_info_p)
-        delete_sx_port_attributes_t_arr(port_attributes_list)
-        delete_uint32_t_p(port_cnt_p)
-
-        return status, label_port_list, module_state,
-
-
-# main start
-def main():
-    log_info("mlnx-sfpd daemon started")
-
-    sfpd = MlnxSfpd()
-    try:
-        sfpd.initialize()
-        sfpd.run()
-    except (RuntimeError, select.error) as err:
-        log_error("error: {}".format(err))
-    finally:
-        sfpd.deinitialize()
-
-    log_info("mlnx-sfpd daemon exited")
-
-
-if __name__ == '__main__':
-    main()
diff --git a/platform/mellanox/mlnx-sfpd/setup.py b/platform/mellanox/mlnx-sfpd/setup.py
deleted file mode 100644
index ea9b895cb1..0000000000
--- a/platform/mellanox/mlnx-sfpd/setup.py
+++ /dev/null
@@ -1,28 +0,0 @@
-from setuptools import setup
-
-setup(
-    name='mlnx-sfpd',
-    version='1.0',
-    description='SFP event mmonitoring daemon for SONiC on mellanox platform',
-    license='Apache 2.0',
-    author='SONiC Community',
-    url='https://github.com/Azure/sonic-buildimage/',
-    maintainer='Kebo Liu',
-    maintainer_email='kebol@mellanox.com',
-    scripts=[
-        'scripts/mlnx-sfpd',
-    ],
-    classifiers=[
-        'Development Status :: 4 - Beta',
-        'Environment :: No Input/Output (Daemon)',
-        'Intended Audience :: Developers',
-        'Intended Audience :: Information Technology',
-        'Intended Audience :: System Administrators',
-        'License :: OSI Approved :: Apache Software License',
-        'Natural Language :: English',
-        'Operating System :: POSIX :: Linux',
-        'Programming Language :: Python :: 2.7',
-        'Topic :: System :: Hardware',
-    ],
-    keywords='sonic SONiC SFP sfp MELLANOX mellanox daemon SFPD sfpd',
-)
diff --git a/platform/mellanox/rules.mk b/platform/mellanox/rules.mk
index c869bfc6cd..dd10cefda5 100644
--- a/platform/mellanox/rules.mk
+++ b/platform/mellanox/rules.mk
@@ -10,7 +10,6 @@ include $(PLATFORM_PATH)/docker-saiserver-mlnx.mk
 include $(PLATFORM_PATH)/one-image.mk
 include $(PLATFORM_PATH)/libsaithrift-dev.mk
 include $(PLATFORM_PATH)/docker-ptf-mlnx.mk
-include $(PLATFORM_PATH)/mlnx-sfpd.mk
 include $(PLATFORM_PATH)/mlnx-ffb.mk
 include $(PLATFORM_PATH)/issu-version.mk