Jaehyeon Kim
Jaehyeon Kim

  • Blog
    • Categories

      List of categories.

    • Tags

      List of tags.

    • Series

      List of series.

    • Archives

  • Projects
  • Slides

/

  • Github Linkedin RSS

  • Font Size
  • Palette
  • Mode
  1. Home
  2. Tags
  3. Kafka Connect

Kafka Development on Kubernetes - Part 3 Kafka Connect

Kafka Development on Kubernetes - Part 3 Kafka Connect
January 11, 20247 min read Data Integration Data-Streaming Kubernetes Kafka Development on KubernetesApache KafkaDockerKafka ConnectKubernetesMinikubePython

Ingest fake customer and order data into Kafka with the MSK Data Generator and save it to S3, with connectors deployed as Strimzi custom resources.

Read More: Kafka Development on Kubernetes - Part 3 Kafka Connect

Write data to DynamoDB using Kafka Connect - Real Time Streaming with Kafka and Flink Lab 5

Write data to DynamoDB using Kafka Connect - Real Time Streaming with Kafka and Flink Lab 5
November 30, 202310 min read Data-Streaming Real Time Streaming With Kafka and FlinkAmazon DynamoDBApache FlinkApache KafkaAWSKafka ConnectKpow

Ingest records from a Kafka topic into a DynamoDB table using the Camel DynamoDB sink connector, defined and run on Kafka Connect.

Read More: Write data to DynamoDB using Kafka Connect - Real Time Streaming with Kafka and Flink Lab 5

Deploy Aiven OpenSearch Sink Connector - Kafka Connect for AWS Services Integration Part 5

Deploy Aiven OpenSearch Sink Connector - Kafka Connect for AWS Services Integration Part 5
October 30, 202318 min read Data-Streaming Kafka Connect for AWS Services IntegrationAmazon MSKAmazon OpenSearch ServiceApache KafkaAWSKafka ConnectKpow

Deploy a Kafka to OpenSearch pipeline on AWS with Terraform, covering a VPC, VPN server, MSK cluster, OpenSearch domain and the MSK Connect connectors.

Read More: Deploy Aiven OpenSearch Sink Connector - Kafka Connect for AWS Services Integration Part 5

Develop Aiven OpenSearch Sink Connector - Kafka Connect for AWS Services Integration Part 4

Develop Aiven OpenSearch Sink Connector - Kafka Connect for AWS Services Integration Part 4
October 23, 202312 min read Data Integration Data-Streaming Kafka Connect for AWS Services IntegrationApache KafkaAWSDockerKafka ConnectKpowOpenSearch

Build a local Kafka to OpenSearch pipeline on Docker with the Aiven sink connector, ingesting fake impressions and clicks for near real time analytics.

Read More: Develop Aiven OpenSearch Sink Connector - Kafka Connect for AWS Services Integration Part 4

Deploy Camel DynamoDB Sink Connector - Kafka Connect for AWS Services Integration Part 3

Deploy Camel DynamoDB Sink Connector - Kafka Connect for AWS Services Integration Part 3
July 3, 202314 min read Data Integration Data-Streaming Kafka Connect for AWS Services IntegrationAmazon DynamoDBAmazon MSKApache CamelApache KafkaAWSKafka ConnectKpow

Deploy the Camel DynamoDB sink connector and its data generator source on Amazon MSK and MSK Connect, moving the local pipeline onto AWS.

Read More: Deploy Camel DynamoDB Sink Connector - Kafka Connect for AWS Services Integration Part 3

Kafka Development with Docker - Part 6 Kafka Connect with Glue Schema Registry

Kafka Development with Docker - Part 6 Kafka Connect with Glue Schema Registry
June 15, 202313 min read Data Integration Data-Streaming Kafka Development With DockerApache KafkaAWSAWS Glue Schema RegistryDockerKafka ConnectKpow

Schema registry support added to a Kafka Connect ingestion pipeline, so the source and sink connectors serialise through AWS Glue Schema Registry.

Read More: Kafka Development with Docker - Part 6 Kafka Connect with Glue Schema Registry

Kafka Development with Docker - Part 5 Glue Schema Registry

Kafka Development with Docker - Part 5 Glue Schema Registry
June 8, 20237 min read Data-Streaming Kafka Development With DockerApache KafkaAWSAWS Glue Schema RegistryKafka ConnectSchema Registry

Build the Glue Schema Registry client library and use it to manage and enforce schemas in Kafka producer and consumer applications.

Read More: Kafka Development with Docker - Part 5 Glue Schema Registry

Develop Camel DynamoDB Sink Connector - Kafka Connect for AWS Services Integration Part 2

Develop Camel DynamoDB Sink Connector - Kafka Connect for AWS Services Integration Part 2
June 4, 202314 min read Data-Streaming Kafka Connect for AWS Services IntegrationAmazon DynamoDBApache CamelApache KafkaAWSDockerKafka Connect

Develop the Camel DynamoDB sink connector on Docker, consuming fake order records from a Kafka topic and writing them into a DynamoDB table.

Read More: Develop Camel DynamoDB Sink Connector - Kafka Connect for AWS Services Integration Part 2

Kafka Development with Docker - Part 3 Kafka Connect

Kafka Development with Docker - Part 3 Kafka Connect
May 25, 20239 min read Data Integration Data-Streaming Kafka Development With DockerApache KafkaDockerKafka Connect

A Kafka Connect ingestion pipeline on Docker. The MSK Data Generator creates fake customer and order records, and the Confluent S3 sink saves them.

Read More: Kafka Development with Docker - Part 3 Kafka Connect

Kafka Connect for AWS Services Integration - Part 1 Introduction

Kafka Connect for AWS Services Integration - Part 1 Introduction
May 3, 20234 min read Data Integration Data-Streaming Kafka Connect for AWS Services IntegrationAmazon MSKApache KafkaAWSKafka Connect

A survey of the Kafka connectors available for AWS service integration, as the starting point for building real time data pipelines on AWS.

Read More: Kafka Connect for AWS Services Integration - Part 1 Introduction
  • ««
  • «
  • 1
  • 2
  • »
  • »»
Profile
Jaehyeon Kim
Jaehyeon Kim
Data Engineer | Data Streaming | Powering ML & AI in Real Time
Taxonomies
Data Streaming 70 Data Engineering 38 Development 28 Data Analysis 17 Data Integration 12 Open Source 7 Kubernetes 6 Machine Learning 5 Security 5 Data Architecture 3 Data Processing 3 Big Data 2 System Architecture 2 Web Development 2
Python 75 Apache Kafka 68 AWS 50 Docker 50 Apache Flink 34 Apache Beam 17 Apache Spark 16 Kafka Connect 15 Amazon MSK 14 AWS Lambda 14 dbt 13 Amazon EMR 11 Kubernetes 8 PyFlink 8 Kotlin 7 PostgreSQL 7 Change Data Capture (CDC) 6 Debezium 6 dynamic-des 6 Amazon DynamoDB 5 Apache Airflow 5 Discrete Event Simulation 5 Factor House Local 5 PySpark 5 Amazon API Gateway 4 Amazon Athena 4 Apache Iceberg 4 AWS Glue 4 AWS Glue Schema Registry 4 BigQuery 4 Digital Twin 4 FastAPI 4 Minikube 4 SimPy 4 Amazon EKS 3 Amazon QuickSight 3 Amazon S3 3 Apache Hudi 3 EMR on EKS 3 GCP 3 ALL 137
Kafka Development with Docker 11 Apache Beam Python Examples 10 Real Time Streaming with Kafka and Flink 7 dbt Pizza Shop Demo 6 Apache Beam Local Development with Python 5 Building Real-Time Digital Twins with dynamic-des 5 dbt for Effective Data Transformation on AWS 5 Getting Started with Real-Time Streaming in Kotlin 5 Kafka Connect for AWS Services Integration 5 Serverless Data Product 4 Data Lake Demo Using Change Data Capture 3 Getting Started with PyFlink on AWS 3 Kafka Development on Kubernetes 3 Parallel processing on single machine 3 Realtime Dashboard with FastAPI, Streamlit and Next.js 3 API development with R 2 dbt Guide for Production 2 Deploy Python Stream Processing App on Kubernetes 2 Download Stock Data 2 From Prototype to Production: Real-Time Product Recommendation with Contextual Bandits 2 ALL 24
2026 11 2025 13 2024 29 2023 39 2022 15 2021 7 2020 1 2019 5 2018 2 2017 6 2016 6 2015 15 2014 5
Posts
  • Building an Agentic Analytics System over an Iceberg Lakehouse
    Building an Agentic Analytics System over an Iceberg Lakehouse
    July 18, 2026
  • Dynamic DES v0.11.1: A Declarative API with Postgres and Redis Connectors
    Dynamic DES v0.11.1: A Declarative API with Postgres and Redis Connectors
    July 17, 2026
  • Introducing odctl: One CLI for a Local Open Data Stack
    Introducing odctl: One CLI for a Local Open Data Stack
    July 16, 2026
  • One Simulation, Two Pipelines: Batch Training and Live Inference with Dynamic DES v0.8.1
    One Simulation, Two Pipelines: Batch Training and Live Inference with Dynamic DES v0.8.1
    May 25, 2026
  • Building an Event-Driven Hybrid Digital Twin with dynamic-des
    Building an Event-Driven Hybrid Digital Twin with dynamic-des
    April 29, 2026
  • Why Digital Twins Are Rewiring Industry 4.0
    Why Digital Twins Are Rewiring Industry 4.0
    April 22, 2026
  • Building a Real-Time Industrial Digital Twin with Apache Flink and Online Machine Learning
    Building a Real-Time Industrial Digital Twin with Apache Flink and Online Machine Learning
    April 21, 2026
  • Slides as Code: Integrating Reveal.js into my Hugo Blog
    Slides as Code: Integrating Reveal.js into my Hugo Blog
    March 9, 2026
  • Productionizing an Online Product Recommender using Event Driven Architecture
    Productionizing an Online Product Recommender using Event Driven Architecture
    February 23, 2026
  • Stream Processing with Flink in Kotlin
    Stream Processing with Flink in Kotlin
    December 10, 2025
  • Building an Agentic Analytics System over an Iceberg Lakehouse
    Building an Agentic Analytics System over an Iceberg Lakehouse
    July 18, 2026
  • Dynamic DES v0.11.1: A Declarative API with Postgres and Redis Connectors
    Dynamic DES v0.11.1: A Declarative API with Postgres and Redis Connectors
    July 17, 2026
  • Introducing odctl: One CLI for a Local Open Data Stack
    Introducing odctl: One CLI for a Local Open Data Stack
    July 16, 2026
  • One Simulation, Two Pipelines: Batch Training and Live Inference with Dynamic DES v0.8.1
    One Simulation, Two Pipelines: Batch Training and Live Inference with Dynamic DES v0.8.1
    May 25, 2026
  • Current London 2026: Building End-to-End Data Lineage
    Current London 2026: Building End-to-End Data Lineage
    May 22, 2026
  • Building an Event-Driven Hybrid Digital Twin with dynamic-des
    Building an Event-Driven Hybrid Digital Twin with dynamic-des
    April 29, 2026
  • Why Digital Twins Are Rewiring Industry 4.0
    Why Digital Twins Are Rewiring Industry 4.0
    April 22, 2026
  • Building a Real-Time Industrial Digital Twin with Apache Flink and Online Machine Learning
    Building a Real-Time Industrial Digital Twin with Apache Flink and Online Machine Learning
    April 21, 2026
  • Slides as Code: Integrating Reveal.js into my Hugo Blog
    Slides as Code: Integrating Reveal.js into my Hugo Blog
    March 9, 2026
  • Productionizing an Online Product Recommender using Event Driven Architecture
    Productionizing an Online Product Recommender using Event Driven Architecture
    February 23, 2026
Actions
Go back Reload Copy URL

Jaehyeon Kim

Data Engineer | Data Streaming | Powering ML & AI in Real Time

Copyright © 2023-2026 Jaehyeon Kim. All Rights Reserved.