Тёмный

🎄Twelve Days of SMT 🎄 - Day 12: Community transformations 

Robin Moffatt
Подписаться 4,2 тыс.
Просмотров 1,9 тыс.
50% 1

Apache Kafka ships with many Single Message Transformations included - but the great thing about it being an open API is that people can, and do, write their own transformations. Many of these are shared with the wider community, and in this final installment of the series I’m going to look at some of the transformations written by Jeremy Custenborder and available in kafka-connect-transform-common which can be downloaded and installed from Confluent Hub (or built from source, if you like that kind of thing). Also check out the XML transformation by the same author.
* Change topic case
* Use the timestamp of a field as the message timestamp
* Add the current timestamp to the message payload
* Using `SimulatorSinkConnector` (and Single Message Transform `TRACE` logging)
---
👾 Demo code and details: github.com/confluentinc/demo-...
Learn more about Kafka Connect here:
🏃‍♂️ Quick: • Kafka Connect in 60 se...
🚶 More detail: rmoff.dev/kafka-connect-zero-...
🗒️ SMT reference: jcustenborder.github.io/kafka...
---
⏱️ Time codes:
00:00:00 Single Message Transform introduction
00:01:18 Finding other Single Message Transforms on GitHub
00:01:36 A little side note about how cool Debezium is 😎
00:03:08 Transforms from Jeremy Custenborder
00:03:59 Generating test data with Kafka Connect and Voluble
00:04:34 Changing the case of a Kafka topic name
00:07:10 Using the timestamp in a message field to set the topic name
00:08:15 Chaining together three transformations
00:11:19 Adding the processing time into a field of a message in Kafka Connect
00:13:01 Kafka Connect SInk Simulator
00:14:35 Examining the output of the Simulator Sink Connector
00:15:23 Using Dynamic Logging in Kafka Connect to see detail of Single Message Transforms
00:16:50 Recap and conclusion
---
☁️ Confluent Cloud: confluent.cloud/signup?...
💾Download Confluent Platform: www.confluent.io/download/?ut...
📺 Kafka Connect connector deep-dives: • Kafka Connect
✍️Kafka Connect documentation: docs.confluent.io/current/con...
🧩Confluent Hub: www.confluent.io/hub/?...

Наука

Опубликовано:

 

3 авг 2024

Поделиться:

Ссылка:

Скачать:

Готовим ссылку...

Добавить в:

Мой плейлист
Посмотреть позже
Комментарии : 5   
@nejbahadnane7517
@nejbahadnane7517 10 месяцев назад
Thanks 🙏 great video
@rmoff
@rmoff 10 месяцев назад
Thanks, glad you liked it :)
@scr33tch
@scr33tch Год назад
Thanks Robin. Your videos are by far the best, most detailed kafka resources.
@rmoff
@rmoff 10 месяцев назад
Thank you! :)
@muks
@muks 2 года назад
Awesome utility of the SMT's. Thanks Robin, Great Video and Great Series, really appreciate it.
Далее
From Zero to Hero with Kafka Connect
33:49
Просмотров 27 тыс.
🔴Ютуб закрывают... Пока?
00:39
Просмотров 1,6 млн
ksqlDB HOWTO: Reserialising data in Apache Kafka
17:42
Просмотров 1,9 тыс.
Data Pipelines: Using CDC to Ingest Data into Kafka
7:20
Water powered timers hidden in public restrooms
13:12
Просмотров 724 тыс.
The moment we stopped understanding AI [AlexNet]
17:38
Просмотров 839 тыс.
ksqlDB HOWTO: Stateful Aggregates
13:56
Просмотров 2,8 тыс.
🎄Twelve Days of SMT 🎄 - Day 8: TimestampConverter
19:14
ksqlDB HOWTO: Schema Manipulation
10:56
Просмотров 1,6 тыс.
Новые iPhone 16 и 16 Pro Max
0:42
Просмотров 2,3 млн