KafkaBroker (Brooklyn)

Overview

Package

Class

Deprecated

Index

Help

Brooklyn

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | METHOD

DETAIL: FIELD | METHOD

brooklyn.entity.messaging.kafka
[Java] Interface KafkaBroker

brooklyn.entity.java.UsesJava
  brooklyn.entity.messaging.kafka.KafkaBroker
      brooklyn.entity.trait.Startable
          brooklyn.entity.rebind.Rebindable
              brooklyn.entity.Entity
                  brooklyn.entity.basic.SoftwareProcess
                      brooklyn.entity.java.UsesJmx
                          brooklyn.entity.messaging.MessageBroker
                              brooklyn.entity.trait.Identifiable
                                  brooklyn.entity.messaging.kafka.Kafka

All Superinterfaces:: UsesJava, Startable, Rebindable, Entity, SoftwareProcess, UsesJmx, MessageBroker, Identifiable, Kafka

@ImplementedBy(KafkaBrokerImpl.class)
public interface KafkaBroker
extends Kafka, MessageBroker, SoftwareProcess, UsesJmx

An Entity that represents a single Kafka broker instance.

Field Summary
`AttributeSensor`	`BROKER_ID`
`AttributeSensor`	`BYTES_RECEIVED`
`AttributeSensor`	`BYTES_SENT`
`AttributeSensor`	`FETCH_REQUEST_COUNT`
`ConfigKey`	`KAFKA_BROKER_CONFIG_TEMPLATE` Location of the configuration file template to be copied to the server.
`PortAttributeSensorAndConfigKey`	`KAFKA_PORT`
`AttributeSensor`	`MAX_FETCH_TIME`
`AttributeSensor`	`MAX_PRODUCE_TIME`
`AttributeSensor`	`PRODUCE_REQUEST_COUNT`
`ConfigKey`	`START_TIMEOUT`
`ConfigKey`	`SUGGESTED_VERSION`
`AttributeSensor`	`TOTAL_FETCH_TIME`
`AttributeSensor`	`TOTAL_PRODUCE_TIME`
`ConfigKey`	`ZOOKEEPER`

Fields inherited from interface Kafka
DOWNLOAD_URL, SUGGESTED_VERSION

Fields inherited from interface MessageBroker
BROKER_URL

Fields inherited from interface SoftwareProcess
ADDRESS, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, DOWNLOAD_URL, HOSTNAME, INSTALL_LATCH, LAUNCH_LATCH, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, SERVICE_STATE, SHELL_ENVIRONMENT, START_LATCH, START_TIMEOUT, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIR, SUGGESTED_VERSION

Fields inherited from interface UsesJmx
DEFAULT_JMX_PORT, JMX_AGENT_MODE, JMX_CONTEXT, JMX_PASSWORD, JMX_PORT, JMX_SSL_ACCESS_CERT, JMX_SSL_ACCESS_KEY, JMX_SSL_ENABLED, JMX_URL, JMX_USER, RMI_REGISTRY_PORT, RMI_SERVER_PORT, USE_JMX

Fields inherited from interface UsesJava
CHECK_JAVA_HOSTNAME_BUG, JAVA_OPTS, JAVA_SYSPROPS

Method Summary
`java.lang.Integer`	`getBrokerId()`
`java.lang.Integer`	`getKafkaPort()`
`Zookeeper`	`getZookeeper()`

Methods inherited from interface MessageBroker
setBrokerUrl

Field Detail

BROKER_ID

public AttributeSensor BROKER_ID

BYTES_RECEIVED

public AttributeSensor BYTES_RECEIVED

BYTES_SENT

public AttributeSensor BYTES_SENT

FETCH_REQUEST_COUNT

public AttributeSensor FETCH_REQUEST_COUNT

KAFKA_BROKER_CONFIG_TEMPLATE

@SetFromFlag("kafkaServerConfig")
public ConfigKey KAFKA_BROKER_CONFIG_TEMPLATE

Location of the configuration file template to be copied to the server.

KAFKA_PORT

@SetFromFlag("kafkaPort")
public PortAttributeSensorAndConfigKey KAFKA_PORT

MAX_FETCH_TIME

public AttributeSensor MAX_FETCH_TIME

MAX_PRODUCE_TIME

public AttributeSensor MAX_PRODUCE_TIME

PRODUCE_REQUEST_COUNT

public AttributeSensor PRODUCE_REQUEST_COUNT

START_TIMEOUT

@SetFromFlag("startTimeout")
public ConfigKey START_TIMEOUT

SUGGESTED_VERSION

@SetFromFlag("version")
public ConfigKey SUGGESTED_VERSION

TOTAL_FETCH_TIME

public AttributeSensor TOTAL_FETCH_TIME

TOTAL_PRODUCE_TIME

public AttributeSensor TOTAL_PRODUCE_TIME

ZOOKEEPER

@SetFromFlag("zookeeper")
public ConfigKey ZOOKEEPER

Method Detail

getBrokerId

public java.lang.Integer getBrokerId()

getKafkaPort

public java.lang.Integer getKafkaPort()

getZookeeper

public Zookeeper getZookeeper()

brooklyn.entity.messaging.kafka [Java] Interface KafkaBroker