Puppet Class: role::kafka::main

Defined in:
modules/role/manifests/kafka/main.pp

Overview

Compound role for the Kafka “main” cluster



2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'modules/role/manifests/kafka/main.pp', line 2

class role::kafka::main {

    include ::profile::firewall
    include ::profile::kafka::broker
    system::role { 'kafka::main':
        description => "Kafka Broker in the main-${::site} Kafka cluster",
    }

    if $::realm == 'production' {
        # Mirror eqiad.* topics from main-eqiad into main-codfw,
        # or mirror codfw.* topics from main-codfw into main-eqiad.
        system::role { 'kafka::mirror':
            description => 'main Kafka cluster cross-DC MirrorMaker node',
        }
        include ::profile::kafka::mirror
    }

    include ::profile::base::production
}