Flatten CDC records in KSQL
The problem - nested messages in Kafka Data comes into Kafka in many shapes and sizes. Sometimes it's from CDC tools, and may be nested like »
Exploring JMX with jmxterm
Check out the jmxterm repository / Download jmxterm from http://wiki.cyclopsgroup.org/jmxterm/ Launch: java -jar ~/Downloads/jmxterm-1.0.0-uber.jar --url localhost:30002 You can »
Window Timestamps in KSQL / Integration with Elasticsearch
KSQL provides the ability to create windowed aggregations. For example, count the number of messages in a 1 minute window, grouped by a particular column: CREATE »
Analysing Network Data with Apache Kafka, KSQL, and Elasticsearch
In this article I demonstrated how to use KSQL to filter streams of network event data. As well as filtering, KSQL can be used to easily »
Stream-Table Joins in KSQL: Stream events must be timestamped after the Table messages
(preserving this StackOverflow answer for posterity and future Googlers) tl;dr When doing a stream-table join, your table messages must already exist (and must be timestamped) »