diff options
Diffstat (limited to 'src/python/netconf_rest_application.py')
| -rw-r--r-- | src/python/netconf_rest_application.py | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/python/netconf_rest_application.py b/src/python/netconf_rest_application.py index b13a084..8376fd8 100644 --- a/src/python/netconf_rest_application.py +++ b/src/python/netconf_rest_application.py @@ -21,7 +21,6 @@ import sys import logging from netconf_server.netconf_app_configuration import NetconfAppConfiguration -from netconf_server.netconf_kafka_client import provide_configured_kafka_client from netconf_server.netconf_rest_server import NetconfRestServer from netconf_server.sysrepo_configuration.sysrepo_configuration_manager import SysrepoConfigurationManager @@ -36,11 +35,7 @@ logger = logging.getLogger("netconf_rest_application") def start_rest_server(session, connection, server_rest: NetconfRestServer, netconf_app_configuration: NetconfAppConfiguration): sysrepo_cfg_manager = create_conf_manager(session, connection) - kafka_client = provide_configured_kafka_client( - netconf_app_configuration.kafka_host_name, - netconf_app_configuration.kafka_port - ) - server_rest.start(sysrepo_cfg_manager, kafka_client, netconf_app_configuration.kafka_topic) + server_rest.start(sysrepo_cfg_manager, netconf_app_configuration) def create_rest_server() -> NetconfRestServer: |