rmoff's random ramblings
Interesting Links Categories Search RSS
Home Categories Interesting Links Search RSS linkedin twitter bluesky youtube talks github
16 Dec 2020 · Kafka Connect

πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 7: TimestampRouter

Just like the RegExRouter, the TimeStampRouter can be used to modify the topic name of messages as they pass through Kafka Connect. Since the topic name is usually the basis for the naming of the …

  • 15 Dec 2020 πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 6: InsertField II
    Kafka Connect
  • 14 Dec 2020 πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 5: MaskField
    Kafka Connect
  • 11 Dec 2020 πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 4: RegExRouter
    Kafka Connect
  • 10 Dec 2020 πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 3: Flatten
    Kafka Connect
  • 09 Dec 2020 πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 2: ValueToKey and ExtractField
    Kafka Connect
  • 08 Dec 2020 πŸŽ„ Twelve Days of SMT πŸŽ„ - Day 1: InsertField (timestamp)
    Kafka Connect
  • 03 Dec 2020 Life as a Developer Advocate, nine months into a pandemic
    DevRel
  • 02 Dec 2020 My Workstation - 2020
    DevRel
  • 13 Nov 2020 Keynote - Why is Replace Fonts greyed out?
    Keynote
  • 03 Nov 2020 Kafka Connect, ksqlDB, and Kafka Tombstone messages
    Kafka
  • 03 Nov 2020 Streaming Geopoint data from Kafka to Elasticsearch
    Kafka Connect
  • 07 Oct 2020 ksqlDB - How to model a variable number of fields in a nested value (STRUCT)
    ksqlDB
  • 05 Oct 2020 Streaming XML messages from IBM MQ into Kafka into MongoDB
    XML
  • 01 Oct 2020 Ingesting XML data into Kafka - Option 3: Kafka Connect FilePulse connector
    XML
  • 01 Oct 2020 Ingesting XML data into Kafka - Option 2: Kafka Connect plus Single Message Transform
    XML
  • 01 Oct 2020 Ingesting XML data into Kafka - Option 1: The Dirty Hack
    XML
  • 01 Oct 2020 Ingesting XML data into Kafka - Introduction
    XML
  • 01 Oct 2020 abcde - Error trying to calculate disc ids without lead-out information
    abcde
  • 01 Oct 2020 IBM MQ on Docker - Channel was blocked
    IBM MQ
  • 30 Sep 2020 Setting key value when piping from jq to kafkacat
    jq
  • 25 Sep 2020 Some of my favourite public data sets
    Datasets
  • 23 Sep 2020 πŸ“Œ 🎁 A collection of Kafka-related talks πŸ’
    Apache Kafka
  • 18 Sep 2020 Using the Debezium MS SQL connector with ksqlDB embedded Kafka Connect
    MS SQL
  • 18 Sep 2020 Including content from external links with Asciidoc in Hugo
    Hugo
  • 11 Sep 2020 What is Kafka Connect?
    Kafka Connect
  • 08 Sep 2020 Counting the number of messages in a Kafka topic
    kcat (kafkacat)
  • 07 Sep 2020 Poking around the search engines in Google Chrome
    sqlite
  • 20 Aug 2020 πŸ€–Building a Telegram bot with Apache Kafka, Go, and ksqlDB
    Go
  • 23 Jul 2020 Telegram bot - BOT_COMMAND_INVALID
    Telegram
  • 23 Jul 2020 Learning Golang (some rough notes) - S02E09 - Processing chunked responses before EOF is reached
    Go
  • 17 Jul 2020 Learning Golang (some rough notes) - S02E08 - Checking Kafka advertised.listeners with Go
    Go
  • 16 Jul 2020 Learning Golang (some rough notes) - S02E07 - Splitting Go code into separate source files and building a binary executable
    Go
  • 15 Jul 2020 Learning Golang (some rough notes) - S02E06 - Putting the Producer in a function and handling errors in a Go routine
    Go
  • 15 Jul 2020 Learning Golang (some rough notes) - S02E05 - Kafka Go AdminClient
    Go
  • 14 Jul 2020 Learning Golang (some rough notes) - S02E04 - Kafka Go Consumer (Function-based)
    Go
  • 14 Jul 2020 Learning Golang (some rough notes) - S02E03 - Kafka Go Consumer (Channel-based)
    Go
  • 10 Jul 2020 Learning Golang (some rough notes) - S02E02 - Adding error handling to the Producer
    Go
  • 08 Jul 2020 Learning Golang (some rough notes) - S02E01 - My First Kafka Go Producer
    Go
  • 08 Jul 2020 Learning Golang (some rough notes) - S02E00 - Kafka and Go
    Go
  • 03 Jul 2020 Learning Golang (some rough notes) - S01E10 - Concurrency (Web Crawler)
    Go
  • 03 Jul 2020 Why JSON isn’t the same as JSON Schema in Kafka Connect converters and ksqlDB (Viewing Kafka messages bytes as hex)
    kcat (kafkacat)
  • 02 Jul 2020 Learning Golang (some rough notes) - S01E09 - Concurrency (Channels, Goroutines)
    Go
  • 02 Jul 2020 Learning Golang (some rough notes) - S01E08 - Images
    Go
  • 01 Jul 2020 Learning Golang (some rough notes) - S01E07 - Readers
    Go
  • 01 Jul 2020 Learning Golang (some rough notes) - S01E06 - Errors
    Go
  • 30 Jun 2020 Learning Golang (some rough notes) - S01E05 - Interfaces
    Go
  • 29 Jun 2020 Learning Golang (some rough notes) - S01E04 - Function Closures
    Go
  • 29 Jun 2020 Learning Golang (some rough notes) - S01E03 - Maps
    Go
  • 25 Jun 2020 Learning Golang (some rough notes) - S01E02 - Slices
    Go
Robin Moffatt
Writing about data engineering, Kafka, Flink, and whatever else catches his eye. Enjoys running, good beer, and fried breakfastsβ€”but not at the same time.
Popular Categories
  • AI (10)
  • Apache Flink (27)
  • Apache Iceberg (8)
  • Checkpoint Chronicle (8)
  • DuckDB (13)
  • Go (22)
  • Golang (22)
  • kafka connect (9)
  • kcat (kafkacat) (23)
  • ksqlDB (28)
  • Single Message Transform (16)
  • Stumbling into AI (11)
  • TwelveDaysOfSMT (13)
View all categories
  • ««
  • «
  • 2
  • 3
  • 4
  • 5
  • 6
  • »
  • »»
© 2026