夢とガラクタの集積場

落ちこぼれ三流エンジニアである管理人の夢想＝『夢』と、潰えた夢＝『ガラクタ』の集積場です。

リアルタイム解析プラットフォームGenn.aiのクライアントを動かしてみる

Storm Kafka Gennai

こんにちは。

昨晩面白そうなページを見つけたので早速試してみました。

リクルートテクノロジー製のリアルタイムプラットフォームで、StormとKafkaを用いて構築されたGenn.ai（源内）です。

■紹介ページ
http://genn.ai/
■登録ページ（動作ホスト兼？）
http://dev.genn.ai/

登録ページで登録してダウンロードしてみると、「gungnir-client.tar.gz」なるファイルがダウンロードされます。
グングニルクライアント？　・・・という形でやたらと格好いい名前ですね。
ともあれ、ダウンロードしたので実際に動作を試してみます。

1. 媒体構成

媒体を展開した結果は以下のようになっていました。
Storm-0.8.2とKafka-0.7.2を用いているようですね。
ですが、StormもKafkaも次の正式バージョンが出る直前で、かつKafkaは既存との互換性がない形になるので、
近いうちにそれなりに大きな修正が必要になりそうなのが微妙なところです。

■gungnir-client.tar.gz

gungnir-client/bin/
gungnir-client/bin/gungnir
gungnir-client/bin/kafka-consumer.sh
gungnir-client/gungnir-client-1.0.0-jar-with-dependencies.jar
gungnir-client/logs/
gungnir-client/conf/
gungnir-client/conf/gungnir.yaml
gungnir-client/conf/kafka-log4j.xml
gungnir-client/conf/log4j.xml
gungnir-client/lib/
gungnir-client/lib/asm-4.0.jar
gungnir-client/lib/jetty-6.1.26.jar
gungnir-client/lib/reflectasm-1.07-shaded.jar
gungnir-client/lib/jackson-mapper-asl-1.9.12.jar
gungnir-client/lib/util-codec_2.9.2-6.3.7.jar
gungnir-client/lib/tools.cli-0.2.2.jar
gungnir-client/lib/guava-11.0.2.jar
gungnir-client/lib/commons-lang-2.5.jar
gungnir-client/lib/commons-lang-2.6.jar
gungnir-client/lib/gungnir-common-1.0.0.jar
gungnir-client/lib/hiccup-0.3.6.jar
gungnir-client/lib/commons-logging-1.1.1.jar
gungnir-client/lib/clojure-1.4.0.jar
gungnir-client/lib/guava-13.0.jar
gungnir-client/lib/curator-framework-1.0.1.jar
gungnir-client/lib/util-logging_2.9.2-6.3.7.jar
gungnir-client/lib/finagle-core_2.9.2-6.5.1.jar
gungnir-client/lib/carbonite-1.5.0.jar
gungnir-client/lib/commons-exec-1.1.jar
gungnir-client/lib/tools.macro-0.1.0.jar
gungnir-client/lib/httpclient-4.1.1.jar
gungnir-client/lib/jsr305-1.3.9.jar
gungnir-client/lib/commons-io-1.4.jar
gungnir-client/lib/core.incubator-0.1.0.jar
gungnir-client/lib/snakeyaml-1.9.jar
gungnir-client/lib/slf4j-log4j12-1.7.5.jar
gungnir-client/lib/jzmq-2.1.0.jar
gungnir-client/lib/servlet-api-2.5.jar
gungnir-client/lib/hamcrest-core-1.3.jar
gungnir-client/lib/finagle-thrift_2.9.2-6.5.1.jar
gungnir-client/lib/jline-2.10.jar
gungnir-client/lib/libthrift-0.8.0.jar
gungnir-client/lib/clout-1.0.1.jar
gungnir-client/lib/activation-1.1.jar
gungnir-client/lib/commons-codec-1.5.jar
gungnir-client/lib/compojure-1.1.3.jar
gungnir-client/lib/clj-time-0.4.1.jar
gungnir-client/lib/libthrift7-0.7.0.jar
gungnir-client/lib/json-simple-1.1.jar
gungnir-client/lib/objenesis-1.2.jar
gungnir-client/lib/commons-fileupload-1.2.1.jar
gungnir-client/lib/tools.logging-0.2.3.jar
gungnir-client/lib/finagle-http_2.9.2-6.5.1.jar
gungnir-client/lib/jackson-core-asl-1.9.12.jar
gungnir-client/lib/jopt-simple-3.2.jar
gungnir-client/lib/zookeeper-3.3.4.jar
gungnir-client/lib/disruptor-2.10.1.jar
gungnir-client/lib/commons-codec-1.4.jar
gungnir-client/lib/util-collection_2.9.2-6.3.7.jar
gungnir-client/lib/util-hashing_2.9.2-6.3.7.jar
gungnir-client/lib/minlog-1.2.jar
gungnir-client/lib/ring-jetty-adapter-0.3.11.jar
gungnir-client/lib/netty-3.6.6.Final.jar
gungnir-client/lib/jline-2.11.jar
gungnir-client/lib/commons-collections-3.2.1.jar
gungnir-client/lib/kryo-2.17.jar
gungnir-client/lib/util-app_2.9.2-6.3.7.jar
gungnir-client/lib/scala-compiler-2.9.2.jar
gungnir-client/lib/ring-core-1.1.5.jar
gungnir-client/lib/httpcore-4.1.3.jar
gungnir-client/lib/math.numeric-tower-0.0.1.jar
gungnir-client/lib/jgrapht-0.8.3.jar
gungnir-client/lib/log4j-1.2.15.jar
gungnir-client/lib/zkclient-0.1.jar
gungnir-client/lib/snappy-java-1.0.4.1.jar
gungnir-client/lib/util-jvm_2.9.2-6.3.7.jar
gungnir-client/lib/core-kafka_2.9.2-0.7.2.jar
gungnir-client/lib/joda-time-2.0.jar
gungnir-client/lib/mail-1.4.jar
gungnir-client/lib/curator-client-1.0.1.jar
gungnir-client/lib/httpcore-4.1.jar
gungnir-client/lib/ring-servlet-0.3.11.jar
gungnir-client/lib/scala-library-2.9.2.jar
gungnir-client/lib/util-core_2.9.2-6.3.7.jar
gungnir-client/lib/commons-cli-1.2.jar
gungnir-client/lib/gungnir-client-1.0.0.jar
gungnir-client/lib/jetty-util-6.1.26.jar
gungnir-client/lib/slf4j-api-1.7.5.jar
gungnir-client/lib/httpclient-4.1.2.jar
gungnir-client/lib/storm-0.8.2.jar
gungnir-client/lib/junit-4.11.jar
gungnir-client/lib/servlet-api-2.5-20081211.jar

その中でgungnir固有のライブラリは以下の２つ。
１．gungnir-common-1.0.0.jar
２．gungnir-client-1.0.0.jar
中身は以下のようになっていました。

■gungnir-common-1.0.0.jar

> jar tvf gungnir-common-1.0.0.jar
     0 Wed Oct 16 15:00:10 JST 2013 META-INF/
   123 Wed Oct 16 15:00:08 JST 2013 META-INF/MANIFEST.MF
     0 Tue Oct 15 20:01:18 JST 2013 ai/
     0 Tue Oct 15 20:01:18 JST 2013 ai/genn/
     0 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/
     0 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/
   702 Sat Oct 05 14:10:12 JST 2013 gungnir-defaults.yaml
  5952 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/GungnirConfig.class
  1884 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/GungnirConst.class
  1979 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/LRUHashSet.class
  2048 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/ConsumerExecutor$1.class
   274 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/ConsumerExecutor$ConsumerListener.class
  3743 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/ConsumerExecutor.class
  1517 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/GungnirUtils$OffsetRequest.class
  1028 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/LRUHashMap.class
  2497 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/utils/GungnirUtils.class
     0 Wed Oct 16 15:00:10 JST 2013 META-INF/maven/
     0 Wed Oct 16 15:00:10 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/
     0 Wed Oct 16 15:00:10 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/gungnir-common/
  3218 Sat Oct 05 17:59:40 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/gungnir-common/pom.xml
   121 Mon Oct 07 01:04:24 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/gungnir-common/pom.properties

■gungnir-client-1.0.0.jar

> jar tvf gungnir-client-1.0.0.jar
     0 Wed Oct 16 15:00:32 JST 2013 META-INF/
   123 Wed Oct 16 15:00:30 JST 2013 META-INF/MANIFEST.MF
     0 Tue Oct 15 20:01:20 JST 2013 ai/
     0 Tue Oct 15 20:01:20 JST 2013 ai/genn/
     0 Tue Oct 15 20:01:20 JST 2013 ai/genn/gungnir/
     0 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/
     0 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/
  2208 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceToClient$4.class
  2864 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_args$createStatement_argsStandardScheme.class
  1394 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_args$closeConnection_argsStandardSchemeFactory.class
  2864 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_args$closeConnection_argsStandardScheme.class
  1426 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_result$createStatement_resultStandardSchemeFactory.class
  1442 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_result$createConnection_resultStandardSchemeFactory.class
  2360 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_args$closeConnection_argsTupleScheme.class
  2842 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$5$1.class
  2594 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_result$execute_resultTupleScheme.class
  1370 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_args$createStatement_argsTupleSchemeFactory.class
  2234 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceToClient$3.class
  3122 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$2$2.class
  3897 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient$createStatement_call.class
  2517 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_args$createConnection_argsTupleScheme.class
  2690 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_result$createStatement_resultTupleScheme.class
  2252 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceToClient$1.class
  1410 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_args$createConnection_argsStandardSchemeFactory.class
  3045 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_args$createConnection_argsStandardScheme.class
 11948 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_result.class
  2232 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceToClient$2.class
  2392 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirServerException$GungnirServerExceptionTupleScheme.class
  3226 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_result$createStatement_resultStandardScheme.class
  3290 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_args$_Fields.class
  4656 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$4.class
 11615 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_result.class
  6164 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Client.class
 11116 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_args.class
  1378 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_args$closeStatement_argsStandardSchemeFactory.class
  4863 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service.class
  8140 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_result.class
  2344 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Processor$closeConnection.class
   836 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceIface.class
  2360 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_args$createStatement_argsTupleScheme.class
  3126 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$1$2.class
  1394 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_args$createStatement_argsStandardSchemeFactory.class
  1253 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirServerException$GungnirServerExceptionStandardSchemeFactory.class
  1229 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirServerException$GungnirServerExceptionTupleSchemeFactory.class
  3289 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_result$_Fields.class
  1410 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_result$closeStatement_resultStandardSchemeFactory.class
  1594 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient$Factory.class
  5348 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient.class
  6684 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceToClient.class
  2663 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Processor$createConnection.class
  3090 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$3$2.class
  2210 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$ServiceToClient$5.class
 10168 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_args.class
  4617 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$3.class
  1402 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_result$createStatement_resultTupleSchemeFactory.class
  3379 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_result$_Fields.class
 11911 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_result.class
  1318 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$5$2.class
  1266 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_args$execute_argsStandardSchemeFactory.class
  3825 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient$closeConnection_call.class
  3289 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_args$_Fields.class
  1759 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_result$closeStatement_resultTupleScheme.class
  1771 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_result$closeConnection_resultTupleScheme.class
  3130 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_result$execute_resultStandardScheme.class
  2834 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Processor.class
  2702 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_result$createConnection_resultTupleScheme.class
  2461 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_result$closeConnection_resultStandardScheme.class
  1402 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_result$closeConnection_resultTupleSchemeFactory.class
  2838 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$4$1.class
  2608 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Processor$createStatement.class
  3238 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_result$createConnection_resultStandardScheme.class
  2449 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_result$closeStatement_resultStandardScheme.class
  1587 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Client$Factory.class
  2345 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_args$closeStatement_argsTupleScheme.class
  3182 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_result$_Fields.class
  1426 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_result$closeConnection_resultStandardSchemeFactory.class
  2925 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$2$1.class
  1298 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_result$execute_resultStandardSchemeFactory.class
  8175 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_result.class
   620 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Iface.class
  4651 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$1.class
  2415 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_args$execute_argsTupleScheme.class
  3927 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient$execute_call.class
  2327 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Processor$closeStatement.class
  3289 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_args$_Fields.class
  1370 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_args$closeConnection_argsTupleSchemeFactory.class
  3812 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient$closeStatement_call.class
  1418 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_result$createConnection_resultTupleSchemeFactory.class
 11418 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_args.class
  1354 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_args$closeStatement_argsTupleSchemeFactory.class
  3172 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_result$_Fields.class
  3172 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirServerException$_Fields.class
  2941 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_args$execute_argsStandardScheme.class
  2850 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_args$closeStatement_argsStandardScheme.class
  1996 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncIface.class
  3277 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_args$_Fields.class
  1318 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$4$2.class
  3376 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_args$_Fields.class
  1386 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_result$closeStatement_resultTupleSchemeFactory.class
  4608 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$2.class
 10168 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeConnection_args.class
  1274 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_result$execute_resultTupleSchemeFactory.class
  1386 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createConnection_args$createConnection_argsTupleSchemeFactory.class
 10121 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$closeStatement_args.class
 11473 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirServerException.class
  2929 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$1$1.class
  1242 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$execute_args$execute_argsTupleSchemeFactory.class
  4661 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$5.class
  1864 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService.class
  3369 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$createStatement_result$_Fields.class
  4022 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$AsyncClient$createConnection_call.class
  2920 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirServerException$GungnirServerExceptionStandardScheme.class
  2893 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Service$3$1.class
  2521 Tue Oct 15 20:01:24 JST 2013 ai/genn/gungnir/thrift/GungnirService$Processor$execute.class
  4907 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClient.class
  1650 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClient$StatementEventListener.class
  1655 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClient$ConnectionEventListener.class
  3733 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClient$Connection.class
  1046 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/Console$2.class
  1661 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClient$CommandResultEventListener.class
   941 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/Console$3.class
  2284 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/Console$1.class
  3052 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClient$Statement.class
   836 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/GungnirClientException.class
 22440 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/Console.class
   586 Tue Oct 15 20:01:22 JST 2013 ai/genn/gungnir/client/ExceptionInfo.class
     0 Wed Oct 16 15:00:32 JST 2013 META-INF/maven/
     0 Wed Oct 16 15:00:32 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/
     0 Wed Oct 16 15:00:32 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/gungnir-client/
  3085 Thu Oct 10 00:42:06 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/gungnir-client/pom.xml
   121 Mon Oct 07 01:05:00 JST 2013 META-INF/maven/jp.co.recruit_tech.atl/gungnir-client/pom.properties

とりあえず、Kafkaでデータを投入して、
操作はGungnirクライアントで表示したコンソールから何かしら入力し、Thriftのインタフェースを叩いて操作する・・・
という構成のようにみえます。

2. 動作結果

媒体の中にあったgungnir／kafka-consumer.shをとりあえず動かしてみることにします。
尚、両方とも接続先は「dev.genn.ai」となっていたため、dev.genn.aiは動作ホストも兼ねているのでしょう。

kafka-consumer.shはtopicを指定して起動するようです。
動かしてみたところ、おそらく動作し、ConsoleConsumerからメッセージが投入されているようです。
■kafka-consumer.sh

> ./kafka-consumer.sh topic
2013-10-21 07:28:32,247 kafka.tools.SimpleConsumerShell$ INFO (Logging.scala:61) Starting consumer...
Test
TestTestTest

では、次はgungnir。
■gungnir

> ./gungnir -u 【GitHubユーザID】-p  【ダウンロード画面で表示されるキー】
10 21, 2013 7:52:24 午前 com.twitter.finagle.Init$ apply
情報: Finagle version 6.5.1 (rev=57de9b06e9d9456abaa98a5b02f085cc029cde41) built at 20130626-111057
Gungnir server connected... dev.genn.ai/54.238.99.212:9190
Welcome kimutansk
gungnir>

と、コンソールが表示されました。
その後、SlideShareにあるようにTuple定義を記述してみたところOKと返ってきましたが、
それ以外のコマンドがわからないため、そこまででした。
これ以上は情報を待つしかないようですね。

gungnir> create tuple TestAction (testid STRING, testvalue STRING);
OK

また情報が出てきたら実際に試してみます。