diff --git a/ui_src/src/components/connectorModal/index.js b/ui_src/src/components/connectorModal/index.js index 96a8401a1..4d9a92f01 100644 --- a/ui_src/src/components/connectorModal/index.js +++ b/ui_src/src/components/connectorModal/index.js @@ -150,7 +150,7 @@ const ConnectorModal = ({ open, clickOutside, newConnecor, source }) => { settings: modifiedSettings, partitions: [stationState?.stationPartition] }); - newConnecor(data?.connector, source); + newConnecor(data?.connector, formFields?.connector_type?.toLocaleLowerCase()); } catch (error) { setError(JSON.stringify(error)); } finally { diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js b/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js index f7b7fa445..c96c15338 100644 --- a/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js +++ b/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js @@ -214,8 +214,9 @@ const ProduceConsumList = ({ producer }) => { }; const handleNewConnector = (connector, source) => { - source ? setConnectorsSourceList([...connectorsSourceList, connector]) : setConnectorsSinkList([...connectorsSinkList, ...connector]); + source === 'source' ? setConnectorsSourceList([...connectorsSourceList, connector]) : setConnectorsSinkList([...connectorsSinkList, connector]); }; + useEffect(() => { if (producer) { let [result, activeConsumers] = concatFunction('producer', stationState?.stationSocketData); @@ -430,7 +431,7 @@ const ProduceConsumList = ({ producer }) => {
+
Partitions: {stationState?.stationMetaData?.partitions_number === 0 ? 1 : stationState?.stationMetaData?.partitions_number} -
)} + + )}