Primitive Keys in ksqlDB
ksqlDB 0.7 adds support for primitive data types as message keys, simplifying data joins and reducing the need for pre-processing.
Robin Moffatt is a Principal DevEx Engineer and seasoned conference speaker with 15+ years of experience presenting at top events like QCon, Devoxx, Kafka Summit, and Strata. He shares insights on developer experience, distributed systems, and cloud technologies through his blog, YouTube, and public talks.
491 articles from this blog
ksqlDB 0.7 adds support for primitive data types as message keys, simplifying data joins and reducing the need for pre-processing.
A quick fix for Fantastical or Mac Calendar not displaying Google Shared Calendars by adjusting sync settings.
A technical guide on configuring Kafka Connect to stream data from Kafka topics into InfluxDB, covering schema requirements and connector setup.
Explains a Kafka Connect ClassCastException error related to schemas and provides solutions for fixing JSON converter configuration.
A technical guide to monitoring Sonos device health by streaming diagnostics data through Kafka, ksqlDB, InfluxDB, and visualizing with Grafana.
How to fix the Java UnsupportedClassVersionError when building a Docker image for ksqlDB by switching to JDK 8.
Explains how to dynamically change Kafka Connect logging levels using its admin API, enabling detailed debugging without restarting workers.
A guide on writing effective conference talk abstracts to increase acceptance chances, based on experience reviewing hundreds of submissions.
A technical exploration of ksqlDB window start times, including creating streams, inserting test data, and querying windowed aggregations.
A technical guide on integrating RabbitMQ with Kafka using Kafka Connect, including setup, schema handling, and use cases.
A technical guide on using ksqlDB and MongoDB to analyze network syslog data from UniFi devices, including Kafka stream processing.
A technical guide on using ksqlDB and Kafka Connect to ingest and analyze Syslog data for detecting SSH attacks.
A technical guide on using SSH and Linux pipes to stream and copy a MongoDB collection from a remote server to a local Docker instance.
Troubleshooting a Kafka Connect 'Request timed out' error caused by a misconfigured offsets.topic.replication.factor setting.
A guide on how to use tcpdump for network troubleshooting within Docker containers by building a custom image and attaching to container networks.
Explains common configuration errors when setting up multiple Kafka Connect workers in a distributed cluster, focusing on network and REST API settings.
A technical tutorial on streaming data from SQL Server to Snowflake using Kafka and Kafka Connect with Debezium for CDC.
A guide to deploying a custom Kafka Connect worker in Docker on Google Cloud Platform, for use with Confluent Cloud.
Fixing the 'Public Key Retrieval is not allowed' error when connecting Debezium to MySQL v8, including authentication protocol solutions.
A technical guide on integrating Kafka Connect and Debezium with Confluent Cloud for streaming data from MySQL.