Kafka — Cris The Dev

Kafka · 2026/10/13 · 9 分で読めます · 217

Kafka の Consumer group による Partition 割り当てと Rebalance の仕組みを理解し、Spring Boot での対応方法を学びます。

Kafka · 2026/10/12 · 8 分で読めます · 312

Debeziumを使ってPostgreSQLのWALを読み込み、すべてのデータ変更をKafkaにプッシュし、Spring Bootで消費。データ書き込みコードの変更は不要です。

Kafka · 2026/10/12 · 10 分で読めます · 98

Spring BootとKafkaでorchestration型のSagaパターンを実装。飛行機チケット、ホテル、支払い予約と、ステップ失敗時の自動補償。

Kafka · 2026/10/12 · 9 分で読めます · 158

データベース書き込みとKafka送信を同時に実行するとイベントが失われやすいです。本記事ではSpring Boot 3とKafkaを使用してOutbox patternを設定し、両者を常に一致させる方法を説明します。

Kafka · 2026/10/12 · 9 分で読めます · 418

Consumer lagの概要、CLIやAdminClient、Micrometerでの測定方法、broker/producer/consumerの監視指標、適切なアラート設定について説明します。

Kafka · 2026/10/12 · 9 分で読めます · 275

Kafkaプロデューサーの acks, enable.idempotence, batch.size, linger.ms を設定してメッセージの損失がなく、重複がなく、高いスループットを実現する

Kafka · 2026/10/12 · 8 分で読めます · 137

Confluent Schema RegistryをAvroやProtobufと組み合わせてSpring Boot 3で使い、Kafkaメッセージフォーマットを管理し、スキーマの安全な進化を実現します。

Kafka · 2026/10/12 · 11 分で読めます · 158

Kafkaを注文のイベントログとして使用：不変のイベントを記録し、リプレイして状態を再構築し、プロジェクションで読み取りモデルを作成します。適用前に知っておくべき制限事項も含まれています。

Kafka · 2026/10/11 · 9 分で読めます · 93

Rebalanceのしくみ、Consumerがメッセージ処理を停止する理由、poll設定、Cooperative Rebalancing、Static Membershipによる最小化方法を解説します。

Kafka · 2026/10/11 · 10 分で読めます · 98

Kafkaがキーからパーティションを選ぶ仕組み、メッセージの順序を保ちながらホットパーティションを作らないキーの選び方、およびSpring Bootでよくある落とし穴について解説します。

Kafka · 2026/10/11 · 8 分で読めます · 105

Spring Boot 3でのKafkaコンシューマーのブロッキング・非ブロッキングリトライ設定、エラーメッセージをデッドレターコピックに送信、動作検証テストの作成方法を解説します。

Kafka · 2026/10/06 · 7 分で読めます · 114

acks、retries、idempotenceがどのように連携して、producerがKafkaにデータを送信する際にメッセージが失われたり重複したりしないようにするのかを学びます。

Kafka · 2026/10/05 · 6 分で読めます · 116

Kafkaの基本的な3つの概念——Topic、Partition、Offset——をSpring Bootの例を交えて解説します。