Package com.netflix.curator.test

Examples of com.netflix.curator.test.TestingServer

39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
    public static void main(String[] args) {
        TestKafkaProducer tkp = null;

        boolean success = false;

        try (TestingServer zookeeperTestServer =  new TestingServer())  {

            final String theTopic = "someTopic-" + new Random().nextInt();

            tkp = new TestKafkaProducer(
                    theTopic,
                    "localhost:" + zookeeperTestServer.getPort(),
                    10);

            tkp.sendMessages();

            tkp.consumeMessages();
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
    public static void main(String[] args) {
        TestKafkaProducer tkp = null;

        boolean success = false;

        try (TestingServer zookeeperTestServer =  new TestingServer())  {

            final String theTopic = "someTopic-" + new Random().nextInt();

            tkp = new TestKafkaProducer(
                    theTopic,
                    "localhost:" + zookeeperTestServer.getPort(),
                    4400);

            tkp.sendMessages();
            tkp.consumeMessages();
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
        {
            tempFile =
                new File(String.format("/tmp/TestZkServerListener-%s", randomUUID().toString()));
            tempFile.mkdir();
            tempFile.deleteOnExit();
            zkTestServer = new TestingServer(ZK_PORT_TEST, tempFile);
            LOGGER.info("zookeeper server running at {}", ZK_PORT_TEST);
        }
        catch (Exception e)
        {
            throw new RuntimeException(e);
View Full Code Here
17
18
19
20
21
22
23
24
25
26
27
    public KafkaTest() {}
   
    public void run() {
        try {
            server = new TestingServer();
            zookeeperConnectionString = server.getConnectString();
            ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(
                    1000, 3);
            CuratorFramework zookeeper = CuratorFrameworkFactory.newClient(
                    zookeeperConnectionString, retryPolicy);
View Full Code Here
TOP

Related Classes of com.netflix.curator.test.TestingServer

  • com.abiquo.testng.TestZkServerListener
  • com.alibaba.jstorm.test.kafka.KafkaTest
  • com.bazaarvoice.curator.test.ZooKeeperTest
  • org.apache.james.mailbox.store.mail.ZooUidProviderTest
  • org.I0Itec.zkclient.ContentWatcherTest
  • org.I0Itec.zkclient.DistributedQueueTest
  • org.I0Itec.zkclient.ServerZkClientTest
  • org.I0Itec.zkclient.testutil.ZkTestSystem
  • org.I0Itec.zkclient.util.ZkPathUtilTest
  • storm.kafka.DynamicBrokersReaderTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.