桃缶食べたい。

Kafka Manager を構築する

$ git clone git@github.com:yahoo/kafka-manager.git

$ ./sbt clean dist

$ bin/kafka-manager -Dkafka-manager.zkhosts=localhost:2181 -Dhttp.port=8080

Sudachi をビルドする

$ git clone git@github.com:WorksApplications/Sudachi.git
$ cd Sudachi

$ mvn clean package

dependencies {
...
  compile group: 'org.apache.kafka', name: 'kafka-clients', version: '2.0.0'
...
}

単一ノード構成で Producer を利用する

kafka-clients をプロジェクトの依存性に追加する

dependencies {
...
  compile group: 'org.apache.kafka', name: 'kafka-clients', version: '2.0.0'
...
}

ver 0.10 の追加機能

Kafka クラスターを構築する

# server-1.properties

# Kafka サーバー（Broker）の ID 値
broker.id=1
# Kafka サーバー（Broker）への接続 URI
listeners=PLAINTEXT://localhost:9093
# Kafka サーバー（Broker）の Zookeeper のホスト/ポート
zookeeper.connect=localhost:2181
# Kafka サーバー（Broker）のデータ保存ディレクトリ
log.dirs=/tmp/kafka-logs-1

# server-2.properties

# Kafka サーバー（Broker）の ID 値
broker.id=2
# Kafka サーバー（Broker）への接続 URI
listeners=PLAINTEXT://localhost:9094
# Kafka サーバー（Broker）の Zookeeper のホスト/ポート
zookeeper.connect=localhost:2181
# Kafka サーバー（Broker）のデータ保存ディレクトリ
log.dirs=/tmp/kafka-logs-2

Kafka をインストールする

$ java -version
java version "1.8.0_181"
Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)

$ wget http://ftp.riken.jp/net/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz

$ tar xvfz kafka_2.11-2.0.0.tgz
# mv kafka_2.11-2.0.0 /usr/local/
# ln -s /usr/local/kafka_2.11-2.0.0 /usr/local/kafka

import 'package:flutter/material.dart';

void main() => runApp(new InfiniteGridViewSampleWidget());

/// 無限にスクロールする GridView サンプルの StatefulWidget
class InfiniteGridViewSampleWidget extends StatefulWidget {
  @override
  InfiniteGridViewSampleState createState() =>
      new InfiniteGridViewSampleState();
}

/// 無限にスクロールする GridView サンプルの State
class InfiniteGridViewSampleState extends State<InfiniteGridViewSampleWidget> {
  // 表示するデータの List。
  // 初期値としてデータを 20 件いれておく。
  final List<int> items = new List.generate(20, (index) => index);

  // GridView を構築して返す。
  // この GridView を末尾までスクロールした場合、表示するデータ件数を増やして追加表示できるようにする。
  //
  // GridView が末尾までスクロールされたかは、GridView に設定した ScrollController によって検知できる。
  //
  // GridView に表示される要素の最大数は、GridView が構築された時点で固定される。
  // そのため、表示するデータ件数を増やすには、再度 GridView を再構築する必要がある。
  @override
  Widget build(BuildContext context) {
    // GridView のスクロールを検知するための ScrollController。
    final ScrollController _scrollController = new ScrollController();
    // ScrollController にイベントリスナーを設定する。
    _scrollController.addListener(() {
      // 最後までスクロールしたら、次のデータを読み込む。
      if (_scrollController.position.maxScrollExtent <=
          _scrollController.position.pixels) {
        // 表示するデータを追加し、ウィジェットを再構築するよう通知する。
        setState(() {
          // 表示するデータにさらに 20 件データを追加する。
          this.items.addAll(
              new List.generate(20, (index) => this.items.length + index));
        });
      }
    });

    // GridView の要素を表示されるタイミングで構築できるように itemBuilder を指定する。
    return new MaterialApp(
      home: new Scaffold(
        // itemBuilder を指定できる GridView.builder() で GridView を構築する。
        body: GridView.builder(
          itemBuilder: (BuildContext context, int index) {
            // itemBuilder は、引数 index の位置にある GridView の要素が表示されるタイミングで
            // 呼び出され、その要素を構築して返す。

            print("make item: ${index}");

            // 引数 index の位置にある GridView の要素を構築して返す。
            return new Center(child: new Text("#${index}"));
          },
          // GridView で表示するデータの件数を設定する。
          // これ以上の件数のデータを表示する場合、新たな itemCount 値を設定して GridView を再構築する必要がある。
          itemCount: items.length,
          // スクロールされたことを検知するため、ScrollController を設定する。
          controller: _scrollController,
          // GridView の要素は横に 3 個ずつ並べてレイアウトする。
          // これは、new GridView.count(crossAxisCount: 3, children: <Widget>[]) に相当する。
          // GridView の要素の配置は SliverGridDelegateWithFixedCrossAxisCount を設定することで指定できる。
          gridDelegate: new SliverGridDelegateWithFixedCrossAxisCount(
            crossAxisCount: 3,
          ),
        ),
      ),
    );
  }
}

事の発端: await をつけているのに処理が進んでしまう

var i = await sumNumber();

import 'dart:async';

main() {
  ready();
  countDown();
  go();
}

void ready() {
  print("Ready set...");
}

void countNumber(number) {
  print(number);
}

void countDown() async {
  // ここで await を使って待機したい
  await countNumber(3);
  countNumber(2);
  countNumber(1);
}

void go() {
  print("Go!!");
}

Ready set...
3
2
1
Go!!

Ready set...
Go!!
3
2
1

Fedora 26 に KVM をインストールする

# dnf install -y qemu-kvm virt-manager virt-install

# cat /sys/module/kvm_intel/parameters/nested 
N

# echo "options kvm_intel nested=1" >> /etc/modprobe.d/qemu-system-x86.conf
# modprobe -r kvm_intel 
# modprobe kvm_intel 

# cat /sys/module/kvm_intel/parameters/nested 
Y

virt-manager でバーチャルマシンを管理する

# gpasswd -a momokan libvirt

$ virt-manager 

Android エミュレーターを起動する

$ emulator -avd Pixel_API_27 -qemu -m 1024 -enable-kvm &