source の次は sink も試します。 データベース準備 mysql> create database myjdbc2; Query OK, 1 row affected (0.00 sec) mysql> use myjdbc2; Database changed mysql> show tables; Empty set (0.00 sec) コンシューマーでメッセージ確認 >bin\windows\…

プラグイン準備 ここから ダウンロード https://www.confluent.io/hub/confluentinc/kafka-connect-jdbc kafka-connect-jdbc-5.3.1.jar を C:\opt\kafka2\libs に配置 mysql-connector準備 ここからダウンロード https://mvnrepository.com/artifact/mysql/m…

kafka connect の FileStreamSource を試した。 properties これから使う config 内の propertiesファイルを確認する。トピックは connect-test。 入口が test.txt。出口がtest.sink.txt。オフセットを /tmp/connect.offsets に記録するんだろう。 connect-s…

windows10 で kafka + php + rdkafka を試したときのメモ。 使ったもの jdk 11.0.2 kafka 2.2.1 https://kafka.apache.org/downloads#2.2.1 C:\opt\kafka22 に配置 PHP 7.1.33 VC14 x64 Thread Safe (2019-Oct-23 12:30:06) https://pecl.php.net/package/rd…

vm 作り直すのも面倒。docker でなんとかしたい。http://wurstmeister.github.io/kafka-docker/ でやるのが有名のようだ。が実際やってみるとメンドクサイ。 こっちが楽じゃないか。 hub.docker.com 気軽に試す kafka と zookeeper 起動 $ curl -sSL https:/…