public class EmbeddedKafka extends Object
Starts Embedded Kafka
Helper class for starting and working with an embedded kafka. This should be used for testing purposes only
| Constructor and Description |
|---|
EmbeddedKafka() |
| Modifier and Type | Method and Description |
|---|---|
static void |
start(int numThreads,
String... queues) |
static void |
stop()
Stops the embedded kafka
|
public static void start(int numThreads,
String... queues)
numThreads - The number of threads availiable to Kafka. This maps to the created kafka partitionsqueues - The names of the kafka queues to createpublic static void stop()
Copyright © 2017 Grakn Labs Ltd. All rights reserved.