Kafka - MySQL

About

Kafka Connect - JDBC Connector

Articles Related

Demo

Start Kafka: Kafka - Confluent Installation and services
Start my Sql: MySQL - Docker
Create a table in a database.

create database kafka;
use kafka;
CREATE
        TABLE demo
        (
            id            INT
          , value       VARCHAR( 255 )
          , create_ts TIMESTAMP DEFAULT CURRENT_TIMESTAMP
          , update_ts TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
        );
insert into demo (id, value) values (1,"Nico");

Documentation / Reference

Inspired by The Simplest Useful Kafka Connect Data Pipeline In The World … or Thereabouts (Part 1) Robin Moffatt

Support

HTTP 500: Problem accessing /connectors

$ confluent load JdbcMysqlConnector01 -d mySQL.json
Warning: Install 'jq' to add support for parsing JSON

<html>
<head>
<meta http-equiv="Content-Type" content="text/html;charset=ISO-8859-1"/>
<title>Error 500 </title>
</head>
<body>
<h2>HTTP ERROR: 500</h2>
<p>Problem accessing /connectors. Reason:
<pre>    Request failed.</pre></p>
<hr /><i><small>Powered by Jetty://</small></i>
</body>
</html>