wtanaka.apache-kafka

Apache Kafkaをインストールします。モニタで運用します。

必要条件:

Javaのインストール（例: https://galaxy.ansible.com/wtanaka/oracle-java/を使用）
Zookeeperのインストール（例: https://galaxy.ansible.com/wtanaka/zookeeper/を使用）

例となるプレイブック

ロールを含めるだけでシンプルなデフォルトインストールが行われます。

- hosts: servers
  roles:
     - role: wtanaka.apache-kafka

プレイブック内でロールを設定できます：

- hosts: servers
  roles:
     - role: wtanaka.apache-kafka
       kafka_env_variables:
         KAFKA_HEAP_OPTS: "-Xmx512m -Xms512m"

または、適切な host_vars または group_vars ファイルで変数を使用することもできます。

利用可能な全ての設定オプションは defaults/main.yml で見ることができます。

  kafka_version: "0.10.0.1"
  kafka_scala_version: "2.11"
  kafka_mirror: 'http://archive.apache.org/dist/kafka'
  kafka_install_chdir: "/opt"
  kafka_user: "kafka"
  kafka_monit_conf_dir: "/etc/monit/conf.d"
  kafka_init_wrapper_prefix: "kafka-"
  kafka_pid_prefix: "/var/run/kafka-"
  kafka_config_prefix: "server-"
  kafka_log_prefix: "/var/log/kafka-"
  # kafka_delete_topic_enable: "false"

  kafka_brokers:
  - broker_id: 0
    listeners: "PLAINTEXT://:9092"
  - listeners: "PLAINTEXT://:9093"
    file_basename: kafka-9093
    log_dirs: /var/lib/kafka/broker-9093
  kafka_config_contents:
    num.network.threads: 3
    num.io.threads: 8
    socket.send.buffer.bytes: 102400
    socket.receive.buffer.bytes: 102400
    socket.request.max.bytes: 104857600
    num.partitions: 1
    num.recovery.threads.per.data.dir: 1
    log.retention.hours: 168
    log.segment.bytes: 1073741824
    log.retention.check.interval.ms: 300000
    zookeeper.connect: "localhost:2181"
    zookeeper.connection.timeout.ms: "6000"
  kafka_more_config: {}
  kafka_env_variables:
    KAFKA_HEAP_OPTS: "-Xmx1G -Xms1G"