WolveKafka - HTTPエンドポイントでKafkaを消費する軽量ツール
Show HN: WolveKafka – Consume Kafka with a plain HTTP endpoint

WolveKafka(WKS)は、Kafkaのコンシューマーグループ管理、バッチ処理、リトライ、デッドレタートピックへの送信、オフセット管理をすべて肩代わりしてくれるツールです。開発者は任意の言語でHTTPエンドポイントを1つ用意し、ビジネスロジックだけに集中できます。アプリケーションにKafkaクライアントを組み込む必要も、JVMやConnectクラスタを用意する必要もありません。429とRetry-Afterによる過負荷保護、設定のホットリロード、PrometheusメトリクスやOpenTelemetryトレースにも対応。Docker Composeで動くデモを使えば、数分でKafkaイベント処理を体験できます。
あなたのサービスはHTTPでバッチを受け取り、各レコードの結果を返すだけ。その後のコミット、リトライ、デッドレター送信はすべてWKSが処理します。