As we already know, to build a Kafka Message producer that we use the Java client library, in particular the producer API (in the following chapters, we will see how to use Kafka Streams and KSQL).
The first thing we need is a data source; to make it simple we need to produce our mock data. Each message will be a health message with all of its attributes. The first step is to build a producer to send these messages in JSON format to a topic, as in the example:
{"event":"HEALTH_CHECK","factory":"Port Roelborough","serialNumber":"QT89-TZ50","type":"GEOTHERMAL","status":"SHUTTING_DOWN","lastStartedAt":"2018-09-13T00:36:39.079+0000","temperature":28.0,"ipAddress":"235.180.238.3"}
{"event":"HEALTH_CHECK...
