CLOVER🍀

That was when it all began.

2017-07-01から1ヶ月間の記事一覧

Apache Kafka(とApache ZooKeeper)をEmbeddedに使う

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

Apache KafkaのConsumer Groupを試す

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

Infinispan 9.1で追加された、Scattered Cacheを試す

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

Apache Kafkaでクラスタを構成してみる

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

Docker Compose 1.13.0から「scale」が非推奨になり、「up --scale」になったという話

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

Apache Kafkaのkafka-console-producer.shでキーを指定する

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

はじめてのHazelcast Jet(Client/Server Distributed Stream API)

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

InfinispanのSpring Session Support(Remote)を試す

前に、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

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