sets up zookeeper test server . concode_field_sep int ZK_CONNECTION_TIMEOUT concode_elem_sep int BROKER_PORT concode_elem_sep ZkUtils zkUtils concode_elem_sep TestingServer zkServer concode_elem_sep int ZK_SESSION_TIMEOUT concode_elem_sep String BROKER_HOST concode_elem_sep KafkaConfig kafkaCfg concode_elem_sep KafkaServer kafkaSrv concode_elem_sep int ZK_PORT concode_field_sep String getBrokerAddress concode_elem_sep Properties getKafkaConfig concode_elem_sep void createTopic concode_elem_sep Properties getProducerConfig concode_elem_sep void sendMessages concode_elem_sep void setupKafkaServer concode_elem_sep File createTmpDir concode_elem_sep String getZookeeperAddress concode_elem_sep void shutdown
void function ( ) { zkServer = new TestingServer ( ZK_PORT , true ) ; Tuple2 < ZkClient , ZkConnection > loc0 = ZkUtils . createZkClientAndConnection ( zkServer . getConnectString ( ) , ZK_SESSION_TIMEOUT , ZK_CONNECTION_TIMEOUT ) ; zkUtils = new ZkUtils ( loc0 . _1 ( ) , loc0 . _2 ( ) , false ) ; }