kafka

Puppuet module to install Apache Kafka service

Whisk Labs

whisklabs

10,313 downloads

8,672 latest version

2.3 quality score

Version information

  • 0.0.6 (latest)
  • 0.0.5
  • 0.0.4
  • 0.0.3
  • 0.0.2
  • 0.0.1
released Feb 18th 2015

Start using this module

Tags: kafka, java, queue

Documentation

whisklabs/kafka — version 0.0.6 Feb 18th 2015

#puppet-kafka

A puppet module for Apache Kafka setup.

Basic Usage

node 'kafka-0' {
    include java

    class { 'kafka':
      broker_id => '0',
      hostname => $::ipaddress_eth1, # $::ipaddress is picked by default
      zookeeper_connect => 'localhost:2181',
      package_url => 'http://mirror.symnds.com/software/Apache/kafka/0.8.1.1/kafka_2.10-0.8.1.1.tgz'
    }
}

Parameters

  • broker_id - cluster-unique Kafka broker id
  • hostname - the hostname to bind. expected to be available for other brokers and clients
  • zookeeper_connect - zookeeper connection string
  • package_url - might use http, ftp, puppet or file scheme
  • statsd_host - the statsd hostname
  • statsd_port - the statsd port
  • statsd_exclude_regex - the statsd exclude.regex eg. (?!(AllTopicsBytesInPerSec|AllTopicsBytesOutPerSec|AllTopicsMessagesInPerSec|AllTopicsFailedProduceRequestsPerSec)).+

Source Code

Whisklabs Github repo