THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
package org.apache.kafka.testkit;
/**
* Runs an in-memory, "embedded" instance of a Kafka broker using a randomly generated port by default.
* <p>
* Requires a running ZooKeeper instance to connect to.
*/
public class EmbeddedBroker {
public EmbeddedBroker(final Map<String, String> configs) throws IOException { ... }
public EmbeddedBroker(final Map<String, String> configs, Time time) throws IOException { ... }
/** Return the broker id */
public int id() { ... }
/**
* The ZooKeeper connection string aka `zookeeper.connect`.
*/
public String zooKeeperConnect() { ... }
/** Return the broker's log directory */
public Path logDir() { ... }
/**
* Stop the broker.
*/
public void stop() { ... }
}
|
| Code Block | ||||
|---|---|---|---|---|
| ||||
package org.apache.kafka.testkit;
public class EmbeddedCluster extends ExternalResource {
/** Create a Kafka cluster with the requested number of brokers and with the provided configs */
public static EmbeddedCluster create(int numBrokers, Map<String, String> configs) { ... }
/** Create a Kafka cluster with one broker per passed map of configs. */
public EmbeddedCluster(Collection<Map<String, String>> configs) {
this.configs = configs;
}
public void start() { ... }
public TestAdmin admin() { ... }
public boolean stopBroker(int brokerId) { ... }
public void stop() { ... }
public List<String> bootstrapServers(String listenerName) { ... }
public String zooKeeperConnectString() { ... }
public List<EmbeddedBroker> brokers() { ... }
public Integer leader(TopicPartition topicPartition) { ... }
}
|
Proposed Changes
We will introduce a new artifact called kafka-testkit that will contain the Java classes for the test library. This module will depend on the clients and core kafka artifacts, but it won't depend on any of the Kafka test artifacts. As such, users won't have our tests on their classpath.
...