最近、Apache Kafkaで遊んでいますが、こう使っているとEmbedded（組み込み）で動かしてみたくなるもの。テストとかで 使ったりとか。なんかできそうだという感じだったので、チャレンジしてみました。こちらに書いてありましたので。Unit testing / How do …

Apache Kafkaには、Consumer Groupという概念があります。Introduction / ConsumersConsumerにラベル付けをすることで、Consumerをグルーピングします。こうすることで、Brokerから配信されるレコードが、そのConsumer Group内の ひとつのConsumerに配信され…

先日、Infinispan 9.1.0.Finalがリリースされました。Infinispan: Infinispan 9.1 "Bastille"新機能もいくつか増えていますが、今回は新しいCache、「Scattered Cache」を試してみたいと思います。 Scattered cacheA new clustered cache, similar to a dist…

Apache KafkaをしばらくSingle Nodeで扱ってきましたが、そろそろクラスタを構成してみたいと思います。クラスタの構成の仕方は、Apache Kafkaのドキュメント、Quick Startを見ると書いてあったりします。Quick Start / Step 6: Setting up a multi-broker c…

Docker Composeで、「scale」コマンドを使用すると起動しているコンテナをスケールさせることができます。docker-compose scaleこちらが、実行すると警告されるようになったという話。例えば、こういうdocker-compose.ymlを用意して docker-compose.yml vers…

Apache Kafkaには付属のツールとして、コンソールを使ったProducer／Consumerが付いています。このうち、Producer（kafka-console-producer.sh）を使った時に、キーを指定してみようというお話。まずは、Apache Kafkaのクラスタを用意します。Brokerは3つ、A…

この前、はじめてHazelcast Jetを使って分散Stream APIでWord Countをしてみたのですが、はじめてのHazelcast Jet（Embedded Distributed Stream API） - CLOVERこの時はEmbedded Modeで書いていました。今度は、同じネタをClient／Server Modeで行ってみた…

前に、Infinispan 9から入ったSpring Sessionのサポート（Embedded Mode）を試しました。InfinispanのSpring Session Support（Embedded）を試す - CLOVER今度は、Remote（Hot Rod）で試してみたいと思います。Externalizing session using Spring Sessionど…

Spring Cloud Streamのドキュメントで、Schema Evolutionというものが載っていて、ちょっと興味があったので 試してみることにしました。Schema evolution supportSpring Cloud Stream Brooklyn.M1 is available Schema Evolutionとは？ Spring Cloud Stream…