org.locationtech.geowave.test.kafka

Class KafkaTestUtils

java.lang.Object

org.locationtech.geowave.test.kafka.KafkaTestUtils

public class KafkaTestUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static File	DEFAULT_LOG_DIR

Constructor Summary

Constructors

Constructor and Description
KafkaTestUtils()

Method Summary

Modifier and Type	Method and Description
static Properties	getKafkaBrokerConfig(String host)
static void	testKafkaIngest(DataStorePluginOptions options, boolean spatialTemporal, String ingestFilePath)
static void	testKafkaStage(String ingestFilePath)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LOG_DIR

protected static final File DEFAULT_LOG_DIR

Constructor Detail

KafkaTestUtils

public KafkaTestUtils()

Method Detail

testKafkaStage

public static void testKafkaStage(String ingestFilePath)
                           throws Exception

Throws:

Exception

testKafkaIngest

public static void testKafkaIngest(DataStorePluginOptions options,
                                   boolean spatialTemporal,
                                   String ingestFilePath)
                            throws Exception

Throws:

Exception

getKafkaBrokerConfig

public static Properties getKafkaBrokerConfig(String host)