org.apache.drill.exec.store.kafka

Class TestKafkaSuit

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.exec.store.kafka.TestKafkaSuit

public class TestKafkaSuit
extends BaseTest

Field Summary

Fields

Modifier and Type	Field and Description
static EmbeddedKafkaCluster	embeddedKafkaCluster

Constructor Summary

Constructors

Constructor and Description
TestKafkaSuit()

Method Summary

Modifier and Type	Method and Description
static void	createTopicHelper(String topicName, int partitions)
static void	initKafka()
static boolean	isRunningSuite()
static void	tearDownCluster()

Methods inherited from class java.lang.Object

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

Field Detail

embeddedKafkaCluster

public static EmbeddedKafkaCluster embeddedKafkaCluster

Constructor Detail

TestKafkaSuit

public TestKafkaSuit()

Method Detail

initKafka

public static void initKafka()
                      throws Exception

Throws:

Exception

isRunningSuite

public static boolean isRunningSuite()

tearDownCluster

public static void tearDownCluster()

createTopicHelper

public static void createTopicHelper(String topicName,
                                     int partitions)
                              throws ExecutionException,
                                     InterruptedException

Throws:

ExecutionException

InterruptedException