kafka-tutorials

kafka-tutorials copied to clipboard

Tracking loss in devices

[]

This can apply to any IoT, but the idea is to write a ksql stream processing app that detects loss. Author of this recipe has creative freedom to define what...

ybyzek

Rework kcat usage

[]

The way `kcat` is used in KT isn't typical since it overrides the `entrypoint` in Docker. See https://github.com/confluentinc/kafka-tutorials/pull/1277 for details.

ybyzek

Add comments to all statements in process.sql files

[]

e.g. https://developer.confluent.io/tutorials/aviation/confluent.html#execute-ksqldb-code is a large block of code with almost no comments. Action: edit all `process.sql` files and add a short comment for each statement

ybyzek

Console Consumer/Producer Series #5 (Intermediate)

[]

Producing/Consuming Protobuf from the command line

bbejeck

Sink Connector Tutorial (Elasticsearch)

[{"_id":"634b39f1299a723cbf3017db","body":"Pausing this recipe until 0.7 GA","issue_id":1660531339531,"origin_id":583484437,"user_origin_id":10521262,"create_time":1581092940,"update_time":1581092940,"id":1665874417020,"updated_at":"2022-10-15T22:53:37.019000Z","created_at":"2022-10-15T22:53:37.019000Z"}]

- Bootstrap Services, including latest ES & Kibana (community version) - Generate some random data for the user (maybe build a helper docker image to help user instead of having...

rspurgeon

Find distinct events in a stream (KStreams)

[]

tlberglund

Console Consumer/Producer Series #6 (Intermediate)

[]

Producing/Consuming JSON from the command line

bbejeck

Using Interactive Queries in Kafka Streams

[]

bbejeck

Augment inventory recipe

[]

Augment recipe for “Optimize omni-channel inventory” at https://developer.confluent.io/tutorials/inventory/confluent.html with a little more color from user-provided slidedeck (see slidedeck -- [internal link](https://confluent.slack.com/archives/C02C5M9A9DG/p1650992874554669))

ybyzek

Cybersecurity: Analyze Packbeat flows

[]

Reference: https://maciejszymczyk.medium.com/ksqldb-real-time-sql-magic-in-the-cybersecurity-scenario-part-1-3232fa711442 Snippet: ``` CREATE TABLE packetbeat_flows_by_1m WITH (KEY_FORMAT='JSON') AS SELECT source -> ip as srcip, source -> port as srcport, destination -> ip as dstip, destination -> port as...

ybyzek