Icon

3. Model Deployment with kafka

3. Model Deployment with kafka
MODEL DEPLOYMENT (using trained model)- in the model deployment stage, trained model saved is being retrieved and use to makepredictions KAFKA CONSUMER (consume data from kafka producer)- kafka consumer consumed the data from the "fraud" topic and immediatey enterto model deployment stage as the input data. SEND THE INFO BACK TO KAFKA- the results then send back as kafka producer in"fraud-response" topic Connect tokafka containerConsumetopic"fraud"from kafkaConvert kafka "fraud" to tablefilter ID columnproduce kafka "fraud-response"to kafka Conncet to kafka producerconvert to JSONload trained modeluse the trained modelto make prediction Kafka Connector Kafka Consumer JSON to Table Column Filter Rule Engine Kafka Producer Kafka Connector Joiner Table to JSON Table Manipulator Keras NetworkReader Keras NetworkExecutor MODEL DEPLOYMENT (using trained model)- in the model deployment stage, trained model saved is being retrieved and use to makepredictions KAFKA CONSUMER (consume data from kafka producer)- kafka consumer consumed the data from the "fraud" topic and immediatey enterto model deployment stage as the input data. SEND THE INFO BACK TO KAFKA- the results then send back as kafka producer in"fraud-response" topic Connect tokafka containerConsumetopic"fraud"from kafkaConvert kafka "fraud" to tablefilter ID columnproduce kafka "fraud-response"to kafka Conncet to kafka producerconvert to JSONload trained modeluse the trained modelto make prediction Kafka Connector Kafka Consumer JSON to Table Column Filter Rule Engine Kafka Producer Kafka Connector Joiner Table to JSON Table Manipulator Keras NetworkReader Keras NetworkExecutor

Nodes

Extensions

Links

Download

To use this workflow in KNIME, download it from the below URL and open it in KNIME:

Download Workflow
Created by: suhaimi
Created at: 2022-06-27
On NodePit since: 2022-08-21
Last update: 2024-11-17
Created with KNIME version: v4.6.1
Tags: kafkadata streamingmodel deployment

Deploy, schedule, execute, and monitor your KNIME workflows locally, in the cloud or on-premises – with our brand new NodePit Runner.

Try NodePit Runner!