Spring Cloud Streamでは、Binderのエラーハンドリングの仕組みとして、Dead Letter Queueというものがあります。 Event Driven Microservices with Spring Cloud Stream #jjug_ccc #ccc_ab3 / Error Handling RabbitMQにDead Letter Exchanges(DLX)というもので備わっているようですが、 RabbitMQ - Dead Letter Exchanges Spring Cloud StreamではApache Kafkaでも近いことができるようです。 今回は、Apache Kafkaを使ってやってみます。 参照するドキュメントは、こちら。 Apache KafkaのConsumerとしての設定。 Apache Kafka Binder / Confi
Building A Streaming Fraud Detection System With Kafka And Python A thorough tutorial to build your first real-world Kafka app in Docker Compose. Welcome to the land of stream processing! Florimond Manca, Sep 20, 2018 This is the second article of my series on building streaming applications with Apache Kafka. If you missed it, you may read the opening to know why this series even exists and what
AWS Big Data Blog Best Practices for Running Apache Kafka on AWS NOTE: This blog post was written before the launch of Amazon MSK, a fully managed, highly available, and secure service for Apache Kafka. We recommend using Amazon MSK instead of running your own Apache Kafka cluster in EC2. If you need to run Apache Kafka on EC2 then you will find this blog is still useful. ——————————————- This post
気になったのでコードを追ったりしてみました。備忘録けんメモ書きです。 そもそもtimeoutがどうやって送信されてどうやってbrokerで受信されているのかが追いにくいのですが、 https://github.com/apache/kafka/blob/0.9.0.0/clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java#L32 https://github.com/apache/kafka/blob/0.9.0.0/core/src/main/scala/kafka/api/ProducerRequest.scala#L31 https://github.com/apache/kafka/blob/0.9.0.0/clients/src/main/java/org/apache/kafka/c
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く