wtanaka.apache-kafka

安装 Apache Kafka，并通过 monit 进行管理。

要求：

• 安装 Java，例如使用 Oracle Java
• 安装 Zookeeper，例如使用 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 中可见：

```yaml 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

一个 file_basename 和 log_dirs -- 这将自动生成一个 Kafka 0.9+ 的代理 ID

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

  进行磁盘 I/O 的线程数

  num.io.threads: 8

  套接字服务器使用的发送缓冲区 (SO_SNDBUF)

  socket.send.buffer.bytes: 102400

  套接字服务器使用的接收缓冲区 (SO_RCVBUF)

  socket.receive.buffer.bytes: 102400

  套接字服务器接受的最大请求大小

  socket.request.max.bytes: 104857600

  每个主题的默认日志分区数。更多分区允许更大的消费并行性，但也会导致更多文件跨越代理。

  num.partitions: 1

  启动时用于日志恢复和关闭时刷新数据目录的每个线程数。建议对于 RAID 数组中的数据目录增加此值。

  num.recovery.threads.per.data.dir: 1

  日志文件的最小年龄以符合删除资格

  log.retention.hours: 168

  日志段文件的最大大小。当达到该大小时，将创建一个新的日志段。

  log.segment.bytes: 1073741824

  检查日志段以查看是否可以根据保留政策删除的时间间隔

  log.retention.check.interval.ms: 300000

  Zookeeper 连接字符串（请参见 Zookeeper 文档以获取详细信息）。

  这是一个以逗号分隔的 host:port 对，应对应于每个 zk 服务器。例如 "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002"。

  您还可以将可选的 chroot 字符串附加到 URL，以指定所有 Kafka znodes 的根目录。

  zookeeper.connect: "localhost:2181"

  连接到 zookeeper 的超时（毫秒）

  zookeeper.connection.timeout.ms: "6000" kafka_more_config: {}

在此设置环境变量，如 KAFKA_HEAP_OPTS 或 KAFKA_JVM_PERFORMANCE_OPTS 等。不支持嵌入的单引号字符。

kafka_env_variables: KAFKA_HEAP_OPTS: "-Xmx1G -Xms1G"

kafka_monit_enabled

默认：true

将其设置为 false 可以禁用 monit .conf 文件的安装，并避免将 monit 服务设置为 started。

kafka_user

默认：kafka

Kafka 进程运行的操作系统用户。此角色还将确保该用户在操作系统上存在。

许可证

GPLv2

作者信息

http://wtanaka.com/