Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                

タグ

関連タグで絞り込む (0)

  • 関連タグはありません

タグの絞り込みを解除

kafkaに関するJ138のブックマーク (8)

  • Kafka in OSX El-Capitan | data flâneur

    Apache Kafka is a highly-scalable publish-subscribe messaging system that can serve as the data backbone in distributed applications. With Kafka’s Producer-Consumer model it becomes easy to implement multiple data consumers that do live monitoring as well persistent data storage for later analysis. STEP 1: Installation, the best way to install the latest version of the Kafka server on OS X and to

    Kafka in OSX El-Capitan | data flâneur
    J138
    J138 2016/03/11
  • Kafkaによるリアルタイム処理

    This document discusses Kafka, a distributed messaging system originally created by LinkedIn and now an Apache project. It provides an overview of how Kafka works and how various companies use it, including for log processing (LinkedIn), analytics (Facebook, Twitter, Google), and integrating with other technologies like Hadoop, Zookeeper, HBase and Storm. It also covers Kafka's scalability, perfor

    Kafkaによるリアルタイム処理
    J138
    J138 2015/11/05
  • Kafkaを使ってチャットツールを作ってみました | Scala Tech Blog

    こんにちは、15卒のフィ(@dxhuy)です。 最近仕事でちょっとKafkaを使う機会がありました。Kafkaは汎用的に色々な用途で使えるとても面白いミドルウェアです。そこでKafkaの知識を深めるために何か作ろうかなと考えて、コマンドラインで実現する簡単なチャットツールを作ってみました。 Kafkaとは Apache Kafka は Publish-Subscribe 型のメッセージングシステムであり、オフライン・オンライン両方のメッセージ取得に適している。これ は大容量のイベントとログデータを低遅延で収集および配信する目的で、当初は LinkedIn で開発された メッセージングシステムであった。 Kafkaでの概念を簡単に説明します: Producer:情報を作る側。 Consumer : 情報を使う側。 Topic: ConsumerがTopicにSubscribeして情報取り出し

    Kafkaを使ってチャットツールを作ってみました | Scala Tech Blog
    J138
    J138 2015/11/05
  • 初めてのSpark streaming 〜kafka+sparkstreamingの紹介〜

    13. ちょっとだけコード(KafkaのStream作成部分) object ActivitySummary{ def main(args: Array[String]){ val conf = new SparkConf().setAppName("ActivitySummary") val ssc = new StreamingContext(conf,Seconds(5)) val kafkaParams = Map[String,String](“metadata.broker.list” -> “172.27.xxx.xx:9092,・・・") val kafkaStream = KafkaUtils.createDirectStream[String,String,StringDecoder,StringDecoder](ssc,kafkaParams,Se t("raw_tr

    初めてのSpark streaming 〜kafka+sparkstreamingの紹介〜
    J138
    J138 2015/11/05
  • Apache Kafka 概要(Design)和訳まとめ - 夢とガラクタの集積場

    こんにちは。ようやく1ページ全てまとめ終わったので、 最後にまとめ投稿として投稿しておきます。 尚、ページは下記です。 http://kafka.apache.org/07/design.html ========== 1.何故Kafkaは作られたのか? 元々はLinkedInのActivity StreamとData Processingをパイプライン式に繋ぐために開発されたプロダクト。 最近はTumblr、DataSiftといった企業でも使用されている。 → SNSや、複数のサービスの情報を統合するようなシステムで使われているようです。 ここでいうActivity Streamとは Webページで閲覧、検索、リンク設定などを行う活動全般を指す。 これらのデータは通常のシステムならば、ログファイルとして出力し、後で別途解析に用いられる。 もう一つ言葉を定義する。 Operational

    Apache Kafka 概要(Design)和訳まとめ - 夢とガラクタの集積場
    J138
    J138 2015/11/05
  • Apache Kafka入門を読んでみました - 夢とガラクタの集積場

    こんにちは。 この間購入した「Apache Kafka入門」を読み終わったので、 どんなかという概要と注意点を書いてみます。 Apache Kafka入門 作者: 伊橋正義,原田勝憲出版社/メーカー: リクルートテクノロジーズ発売日: 2014/04/01メディア: Kindle版この商品を含むブログ (1件) を見る どんな?/読んでみての感想 一言で言うと、 「内部構造や利用時の実装方法について詳細に書かれたJava開発者向けのKafka入門」でした。 #Kafka自体はScala製ですが、このScala使いではなく、Java開発者向けです。 特に、Broker/Producer/Consumerのコンポーネント構造や Kafkaのシェルで起動可能なクラスといった情報はコードを読み解かないとわからないため、貴重な情報だと思います。 Kafkaを利用する場合の各パターンについて

    Apache Kafka入門を読んでみました - 夢とガラクタの集積場
    J138
    J138 2015/11/05
  • 高速にApache Kafkaを試す - Qiita

    Deleted articles cannot be recovered. Draft of this article would be also deleted. Are you sure you want to delete this article?

    高速にApache Kafkaを試す - Qiita
    J138
    J138 2015/11/05
  • Apache Kafkaに入門した

    Apache kafka 最近仕事でApache Kafkaの導入を進めている.Kafkaとは何か? どこで使われているのか? どのような理由で作られたのか? どのように動作するのか(特にメッセージの読み出しについて)? を簡単にまとめておく(メッセージングはまだまだ勉強中なのでおかしなところがあればツッコミをいただければ幸いです). バージョンは 0.8.2 を対象に書いている. Apache Kafkaとは? 2011年にLinkedInから公開されたオープンソースの分散メッセージングシステムである.Kafkaはウェブサービスなどから発せられる大容量のデータ(e.g., ログやイベント)を高スループット/低レイテンシに収集/配信することを目的に開発されている.公式のトップページに掲載されているセールスポイントは以下の4つ. Fast とにかく大量のメッセージを扱うことができる Scal

    J138
    J138 2015/11/05
  • 1