2017-08-01から1ヶ月間の記事一覧
ふと、RabbitMQに対して、JavaScript(Node.js)クライアントからアクセスしてみたくなりまして。RabbitMQのチュートリアルにある、こちらの2つを自分でも動かしてみることにしました。RabbitMQ - RabbitMQ tutorial - Work QueuesRabbitMQ - RabbitMQ tutor…
Hazelcast Jetのドキュメントには、2つのGetting Startedが載っています。Hazelcast Jet 101 - Word Counting Batch Job - Hazelcast Jet Reference ManualHazelcast Jet 102 - Trade Monitoring Streaming Job - Hazelcast Jet Reference Manual少し前に、W…
Infinispan 9.1から、新機能としてClustered Countersが追加されました。Infinispan: Cluster CounterClustered Counters9.1からと言いつつ、実は9.0.2でも使えるようになっている感じがあります。今回は、このClustered Countersを見ていってみようと思いま…
Apache Kafkaに対して、たまにはJava以外からもアクセスしてみようかなと、JavaScriptのクライアントを試してみることにしました。今回使ったのは、こちら。kafka-node - npmGitHub - SOHU-Co/kafka-node: Node.js client for Apache Kafka 0.8 and later.Pr…
Spring Cloud Streamでは、Binderのエラーハンドリングの仕組みとして、Dead Letter Queueというものがあります。Event Driven Microservices with Spring Cloud Stream #jjug_ccc #ccc_ab3 / Error HandlingRabbitMQにDead Letter Exchanges(DLX)というも…
Hazelcast JetのGetting Startedに載っているのは、Hazelcast Jet上でStream APIを分散実行してWordCountするものでした。Get Started - Hazelcast - High-Performance Stream Processingマニュアルの方では、もう一歩進んでDAGベースのジョブ定義がしてある…