Ponz Dev Log

ゆるくてマイペースな開発日記

Kafka

Kafka本の商業版を出します

技術書典で頒布した「Kafkaをはじめる」を、インプレスR&D様から商業版として出すことになりました。 同人版では書ききれなかった以下の内容を追加して、全体的に書き直しています。 Apache Kafka v3.x系への対応 トランザクションの仕組みと実装 (Producer…

DebeziumでPostgreSQLをCDCするときはロールにSELECT権限をつける

久しぶりにKafkaネタです。 Change Data Capture (CDC)でデータベースの変更をKafkaのイベントに変換するDebeziumを触り始めています。 PostgreSQLのレコードをKafkaに流すときに権限周りでハマったので、備忘録として残します。 Debeziumのおさらい Debeziu…

Apicurio Registry Serdes v2系でKafkaのメッセージをシリアライズする

Kafkaのメッセージをスキーマ言語でシリアライズ/デシリアライズするためには、 専用のライブラリ(Serdes)が必要になります。 Serdesの1つであるApicurio Registry SerdesをJava/Kotlinで使っていたら、 v1系(1.y.z)とv2系(2.y.z)でパッケージ名など大きく変…

MavenでAvroのスキーマファイルからJavaコードを生成するのにつまづいた

Kafka Tutorialsを進めていたときに、タイトル通りMavenでAvroのスキーマからJavaのコード生成するのにつまづいた話です。 このサイトに掲載されているサンプルコードは全てGradleでビルドされているのですが、自分が良く使っているMavenだったらどうかなと…

技術書典8でKafka本を出します

前回の技術書典7に引き続き、技術書典8でも技術同人誌を出すことになりました! 2月になると宣伝する余裕がなさそうなので、今のうちに宣伝しておきます。 techbookfest.org 今回出す本 今回は分散ストリーミングプラットフォームのKafkaの解説同人誌を出す…