Class EmbeddedKafkaBroker.EmbeddedZookeeper

  • Enclosing class:
    EmbeddedKafkaBroker

    public static final class EmbeddedKafkaBroker.EmbeddedZookeeper
    extends java.lang.Object
    Ported from scala to allow setting the port.
    Since:
    2.3
    Author:
    Gary Russell
    • Constructor Detail

      • EmbeddedZookeeper

        public EmbeddedZookeeper​(int zkPort)
                          throws java.io.IOException,
                                 java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.lang.InterruptedException
    • Method Detail

      • getPort

        public int getPort()
      • getSnapshotDir

        public java.io.File getSnapshotDir()
      • getLogDir

        public java.io.File getLogDir()
      • shutdown

        public void shutdown()
                      throws java.io.IOException
        Throws:
        java.io.IOException