maiha

maiha / build.sbt

Last active December 1, 2015 10:25

	libraryDependencies ++= Seq(
	"com.github.xuwei-k" %% "msgpack4z-core" % "0.2.0",
	"com.github.xuwei-k" % "msgpack4z-java07" % "0.2.0"
	)

maiha / 0.migrate kafka from 0.8 to 0.9.md

Last active January 20, 2017 05:00

migrate kafka from 0.8 to 0.9

tips for 0.9

maiha / タイムテーブル.md

Last active November 20, 2015 13:29

1121

1410 JR神田駅 (集合)
1420 カープ（到着＆食事）
1522 JR神田駅 (出発)
1528 JR新橋駅 (到着)
1535 ゆりかもめ新橋駅（出発）
1550 ゆりかもめ台場駅（到着）
1600 シネマメディアージュ（開場）
1615 舞台挨拶開始
1645 上映開始

maiha / 1.undefined-reference.md

Last active October 8, 2015 08:35

crystalでundefined referenceが出たら古い使ってないライブラリを消すべし

% cat /etc/redhat-release
Scientific Linux release 6.5 (Carbon)

maiha / 1.info.log

Last active August 29, 2015 14:25

2015/07/27 parted /dev/sda

	# parted /dev/sda
	(parted) print
	モデル: VMware, VMware Virtual S (scsi)
	ディスク /dev/sda: 107GB
	セクタサイズ (論理/物理): 512B/512B
	パーティションテーブル: msdos

	番号開始終了サイズタイプファイルシステムフラグ
	1 1049kB 43.1GB 43.1GB primary ext4 boot
	2 43.1GB 53.7GB 10.6GB extended

maiha / 1.setup.log

Created July 27, 2015 03:53

2015/07/27 ansible-sevenでbundle ex kitchen setup

	Step 26 : RUN rm -fr /tmp/ansible*
	---> Using cache
	---> b7fe49f6b0cb
	Successfully built b7fe49f6b0cb
	time="2015-07-27T11:14:01+09:00" level=fatal msg="Error response from daemon: Could not get container for seven_zookeeper"
	>>>>>> ------Exception-------
	>>>>>> Class: Kitchen::ActionFailed
	>>>>>> Message: Failed to complete #create action: [Expected process to exit with [0], but received '1'
	---- Begin output of docker run -d -t --name seven_manage --net bridge -h seven-local-manage01 -p 18080:8080 --link seven_zookeeper:zk --link seven_kafka:kafka --link seven_zabbix_server:zabbix-server --expose 10050 b7fe49f6b0cb sh -c 'while true; do sleep 1d; done;' ----
	STDOUT:

maiha / kafka-consumer.scala

Created July 6, 2015 16:30

	import seven.kafka.consumer._

	val options = KafkaBasicConsumer.defaultOptions ++ Map("auto.commit.enable" -> "true")

	def consume(t: String, g: String): Unit = {
	val consumer = new KafkaBasicConsumer("localhost:2181", g, options)
	consumer.basicConsume(t, DefaultCallback)
	Thread.sleep(1000)
	consumer.shutdown()
	}

maiha / 1.基本.md

Last active August 29, 2015 14:23

ThreadPoolの調査

ThreadPoolの種類

maiha / FSM.scala

Created June 21, 2015 14:30

FSMでStateが利用するDataを型安全にする

	onTransition {
	case _ -> AdapterConsuming if ! nextStateData.isInstanceOf[ConsumingData] =>
	throw new IllegalArgumentException(s"AdapterConsuming expects ConsumingData, but got ${nextStateData.getClass.getSimpleName}".red)
	}

maiha / docker-kafka.zsh

Last active August 29, 2015 14:23

	function docker-port-mappings() {
	local x=""
	for x in $(docker ps -q); docker port $x
	}

	function docker-kafka-iptables() {
	local hp="host port"
	local gp="guest port"
	for hp in 2181 9092; do
	for gp in $(docker-port-mappings \|grep $hp \| head -1 \| sed -r "s/.:(.)/\1/g"); do