Icon

2. Kafka Producer

2. Kafka Producer
DATA RETRIEVE FROM DATABASEData from is being retrieved from a database KAFKA PRODUCERThen, it being send to another remote port using kafka producerin "fraud" topic DATA EVENT STREAMING WITH APACHE KAFKAKafka is a data even driven streaming that eable producer to send data in JSON format to the consumer.Working Scenario:- suppose there is real-time data in the database- the data is retrieve from the MySQL database and send to kafka topic in kafka producer.- kafka consumer consume the data from kafka producer and enter model deployment workflow to make prediction Select the tablein the databaseRead the Databaseproduce kafka " fraud" convert to JSONConnect tokafka containerconnect to MYSQL DB Table Selector DB Reader Kafka Producer Table to JSON Kafka Connector MySQL Connector DATA RETRIEVE FROM DATABASEData from is being retrieved from a database KAFKA PRODUCERThen, it being send to another remote port using kafka producerin "fraud" topic DATA EVENT STREAMING WITH APACHE KAFKAKafka is a data even driven streaming that eable producer to send data in JSON format to the consumer.Working Scenario:- suppose there is real-time data in the database- the data is retrieve from the MySQL database and send to kafka topic in kafka producer.- kafka consumer consume the data from kafka producer and enter model deployment workflow to make prediction Select the tablein the databaseRead the Databaseproduce kafka " fraud" convert to JSONConnect tokafka containerconnect to MYSQL DB Table Selector DB Reader Kafka Producer Table to JSON Kafka Connector MySQL Connector

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-12-17
Created with KNIME version: v4.6.0
Tags: kafkadata streaming

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

Try NodePit Runner!