org.apache.drill.exec.store.kafka.cluster

Class EmbeddedKafkaCluster

java.lang.Object

org.apache.drill.exec.store.kafka.cluster.EmbeddedKafkaCluster

All Implemented Interfaces:

TestQueryConstants

public class EmbeddedKafkaCluster
extends Object
implements TestQueryConstants

Field Summary

Fields inherited from interface org.apache.drill.exec.store.kafka.TestQueryConstants

AVRO_TOPIC, BROKER_DELIM, INVALID_TOPIC, JSON_PUSHDOWN_TOPIC, JSON_TOPIC, KAFKA_MSG_OFFSET_FIELD, KAFKA_MSG_TIMESTAMP_FIELD, KAFKA_PARTITION_ID_FIELD, LOCAL_HOST, MAX_CLIENT_CONNECTIONS, MAX_OFFSET_QUERY, MIN_OFFSET_QUERY, MSG_COUNT_QUERY, MSG_SELECT_QUERY, QUERY_TEMPLATE_AND, QUERY_TEMPLATE_AND_OR_PATTERN_1, QUERY_TEMPLATE_AND_OR_PATTERN_2, QUERY_TEMPLATE_AND_OR_PATTERN_3, QUERY_TEMPLATE_BASIC, QUERY_TEMPLATE_OR, TICK_TIME, ZK_TMP

Constructor Summary

Constructors

Constructor and Description
EmbeddedKafkaCluster()
EmbeddedKafkaCluster(Properties props)
EmbeddedKafkaCluster(Properties baseProps, int numberOfBrokers)

Method Summary

Modifier and Type	Method and Description
List<kafka.server.KafkaServer>	getBrokers()
String	getKafkaBrokerList()
Properties	getProps()
ZookeeperHelper	getZkServer()
void	registerToClose(AutoCloseable autoCloseable)
void	setBrokers(List<kafka.server.KafkaServer> brokers)
void	shutDownBroker(int brokerId)
void	shutDownCluster()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EmbeddedKafkaCluster

public EmbeddedKafkaCluster()
                     throws IOException

Throws:

IOException

EmbeddedKafkaCluster

public EmbeddedKafkaCluster(Properties props)
                     throws IOException

Throws:

IOException

EmbeddedKafkaCluster

public EmbeddedKafkaCluster(Properties baseProps,
                            int numberOfBrokers)
                     throws IOException

Throws:

IOException

Method Detail

shutDownCluster

public void shutDownCluster()

shutDownBroker

public void shutDownBroker(int brokerId)

getProps

public Properties getProps()

getBrokers

public List<kafka.server.KafkaServer> getBrokers()

setBrokers

public void setBrokers(List<kafka.server.KafkaServer> brokers)

getZkServer

public ZookeeperHelper getZkServer()

getKafkaBrokerList

public String getKafkaBrokerList()

registerToClose

public void registerToClose(AutoCloseable autoCloseable)