タグ

kafkaに関するetakahaのブックマーク (7)

  • Apache Kafkaとストリーム処理/Reactive Streams

    2018-05-26に行われた「JJUG CCC 2018 Spring」で発表した時の資料です。

    Apache Kafkaとストリーム処理/Reactive Streams
  • Kafka vs Pulsar @KafkaMeetup_20180316

    え、まって。その並列分散処理、Kafkaのしくみでもできるの? Apache Kafkaの機能を利用した大規模ストリームデータの並列分散処理 え、まって。その並列分散処理、Kafkaのしくみでもできるの? Apache Kafkaの機能を利用した大規模ストリームデータの並列分散処理 (NTTデータ テクノロジーカンファレンス 2019 講演資料、2019/09/05) NTTデータ 技術革新統括部 システム技術部生産技術部 インテグレーション技術センタ データ活用チーム 佐々木 徹

    Kafka vs Pulsar @KafkaMeetup_20180316
    etakaha
    etakaha 2018/05/11
    KafkaとPulsarの比較
  • デブサミ2018 Apache Kafkaの話

    Developers Summit2018でのスライド資料です "Apache Kafkaによるスケーラブル アプリケーション開発"

    デブサミ2018 Apache Kafkaの話
  • 25K request/secをさばいた「LINEのお年玉」のアーキテクチャの裏側 - LINE ENGINEERING

    みなさんこんにちは、LINEのサーバーサイドエンジニアの長谷部です。普段は、最近でいうとLINE Login や LINE Customer Connect などの開発を担当しています。 2018年の年始に LINEのお年玉 というイベントを実施し、その開発を担当しました。今回の記事では、LINEのお年玉のアーキテクチャの紹介や、当日実際に発生した問題(サービス過負荷起因のkafka consumer遅延)などの振り返りについて書こうと思います。 LINEのお年玉とは お年玉イベント期間中に、お年玉とLINEスタンプをセットで「お年玉つきスタンプ」として販売しました。対象スタンプを購入したユーザーさんは、スタンプ購入数 x 10個 のお年玉が付与されます。 こういったメッセージが受信されます ユーザーは自分がもっているお年玉を友だちに直接送ったりグループに送信することができ、お年玉を受け取

    25K request/secをさばいた「LINEのお年玉」のアーキテクチャの裏側 - LINE ENGINEERING
  • Kafka Java Consumer Client小技 - 烏滑稽

    Distributed computing Advent Calendar 2017の12/16分の投稿です。 qiita.com clientコードでよく使われるテクニック、というわけではなく 自分が勝手によく使っている小技の紹介です。 今回扱うKafka Java Clientのバージョンは1.0ではなく残念ながら0.10.1.1です・・・今キャッチアップしてないんですよね。 他にいい小技や改善案などあればコメントで教えてください。 RPS調整(EPS) サンプリング RPS調整とサンプリングの合わせ技 トピック毎の流量調整(おまけ) 考え方 処理スレッドを増やす オフセット強制最新 batch consumer(startとstop) consumerの割当はconsumer groupの機能を使い、それ以降は使わずに固定する おわり RPS調整(EPS) Kafkaは一般に流量に強

    Kafka Java Consumer Client小技 - 烏滑稽
  • Apache Kafkaを使ったアプリ設計で反省している件を正直ベースで話す

    Apache Kafka: Producer, Broker and Consumer2017年は生まれて始めてApache Kafkaを格的に業務利用(PoCではなく番運用)した年でした。Apache Kafka的なメッセージングミドルウェアそのもののは、社内的な事情でよく使っていたのでその使い勝手に対して困惑はほとんど無かったですし、ミドルウェアとして非常に安定しているため、Kafkaクラスタそのものでの不具合らしい不具合が発生したことは一度もありませんでした。 しかし、Kafkaのトピック設計などに関してのベストプラクティスは事例ベースでもあまり見かけたことがなく、チームメンバーと悩むことも多かったです。このストーリーでは、主にKafkaを利用したアプリ設計で考えたことや失敗したことを振り返りつつ共有します。なお、パーティション数や各種バッファサイズなどのチューニング要素は今回取

    Apache Kafkaを使ったアプリ設計で反省している件を正直ベースで話す
  • tcpdumpからKafkaのリトライ可能エラーを追う - n-agetsumaの日記

    Kafkaのメッセージロストの原因の1つに、プロデューサの設定のretries(デフォルト0:リトライしない)の未設定がある。 Kafkaクライアントの送信リトライ プロデューサからメッセージ送信時のエラーには、retires設定によりKafkaのクライアントライブラリ内で自動リトライ可能なエラーと、リトライせずにProducer.sendメソッドの呼び出し元に例外を投げるエラーがある。自動リトライ可能なエラーで発生する例外は、org.apache.kafka.common.errors.RetriableExceptionの継承クラスである。代表的なものを以下に示す。 retiresによりリトライするエラー NotLeaderForPartitionException リーダーパーティションではないブローカーにメッセージが送られた場合のエラー応答。ブローカー障害によるフェールオーバ中にメ

    tcpdumpからKafkaのリトライ可能エラーを追う - n-agetsumaの日記
  • 1