I am trying to use curator's embedded Zookeeper TestingServer to do my
tests. Here is the simplest generic test class I could come up with that
displays the error. Has anyone seen this?
package com;
import java.io.IOException;
import java.util.Properties;
import kafka.server.KafkaConfig;
import kafka.server.KafkaServerStartable;
import kafka.utils.TestUtils;
import org.apache.curator.test.TestingServer;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.powermock.core.classloader.annotations.PowerMockIgnore;
import org.powermock.modules.junit4.PowerMockRunner;
@RunWith(PowerMockRunner.class)
@PowerMockIgnore("javax.management.*")
public class TestMe {
KafkaServerStartable kafkaServer;
TestingServer zkServer;
public TestMe() throws Exception {
zkServer = new TestingServer();
KafkaConfig config = getKafkaConfig(zkServer.getConnectString());
kafkaServer = new KafkaServerStartable(config);
kafkaServer.startup();
}
private static KafkaConfig getKafkaConfig(final String zkConnectString)
{
scala.collection.Iterator<Properties> propsI =
TestUtils.createBrokerConfigs(1, true).iterator();
assert propsI.hasNext();
Properties props = propsI.next();
assert props.containsKey("zookeeper.connect");
props.put("zookeeper.connect", zkConnectString);
return new KafkaConfig(props);
}
public String getKafkaBrokerString() {
return String.format("localhost:%d",
kafkaServer.serverConfig().port());
}
public String getZkConnectString() {
return zkServer.getConnectString();
}
public int getKafkaPort() {
return kafkaServer.serverConfig().port();
}
public void stop() throws IOException {
kafkaServer.shutdown();
zkServer.stop();
}
@Test
public void test00() throws Exception {
}
}
The error I am getting is this:
10:29:50.374 [Thread-0] ERROR o.a.c.test.TestingZooKeeperServer - From
testing server (random state: false) for instance:
InstanceSpec{dataDirectory=/var/folders/51/7vtgpj8938j5snr6f49l3qzh0000gn/T/1418315390050-0,
port=58985, electionPort=58986, quorumPort=58987,
deleteDataDirectoryOnClose=true, serverId=1, tickTime=-1,
maxClientCnxns=-1} org.apache.curator.test.InstanceSpec@e669
java.lang.ClassCastException: class sun.security.provider.ConfigFile
at java.lang.Class.asSubclass(Class.java:3293) ~[na:1.8.0_05]
at javax.security.auth.login.Configuration$2.run(Configuration.java:254)
~[na:1.8.0_05]
at javax.security.auth.login.Configuration$2.run(Configuration.java:247)
~[na:1.8.0_05]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.8.0_05]
at javax.security.auth.login.Configuration.getConfiguration(
Configuration.java:246) ~[na:1.8.0_05]
at org.apache.zookeeper.server.ServerCnxnFactory.configureSaslLogin(
ServerCnxnFactory.java:174) ~[na:3.4.6-1569965]
at org.apache.zookeeper.server.NIOServerCnxnFactory.configure(
NIOServerCnxnFactory.java:87) ~[na:3.4.6-1569965]
at org.apache.zookeeper.server.ZooKeeperServerMain.runFromConfig(
ZooKeeperServerMain.java:111) ~[na:3.4.6-1569965]
at org.apache.curator.test.TestingZooKeeperMain.runFromConfig(
TestingZooKeeperMain.java:73) ~[na:2.7.0]
at org.apache.curator.test.TestingZooKeeperServer$1.run(
TestingZooKeeperServer.java:148) ~[na:2.7.0]