Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Kicking the tires on 0.8.1...tires kicking back


Copy link to this message
-
Re: Kicking the tires on 0.8.1...tires kicking back
Edward Capriolo 2014-03-30, 18:02
The same code works when I switch to 0.8.0
             <dependency>
                        <groupId>org.apache.kafka</groupId>
                        <artifactId>kafka_2.9.2</artifactId>
                       <version>0.8.0</version>
                </dependency>

And use my own

  public static void createTopic(String name, int replica, int partitions )
{
    String[] arguments = new String[8];
    arguments[0] = "--zookeeper";
    arguments[1] = "localhost:"+zookeeperTestServer.getPort();
    arguments[2] = "--replica";
    arguments[3] = replica+"";
    arguments[4] = "--partition";
    arguments[5] = partitions+"";
    arguments[6] = "--topic";
    arguments[7] = name;

    CreateTopicCommand.main(arguments);
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
On Sun, Mar 30, 2014 at 12:30 PM, Edward Capriolo <[EMAIL PROTECTED]>wrote: