public class PedestrianAttrRecogAppTest extends Object
Modifier and Type | Field and Description |
---|---|
private org.apache.kafka.clients.consumer.KafkaConsumer<String,byte[]> |
consumer
|
private ConsoleLogger |
logger
|
private org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> |
producer
|
private PedestrianAttrRecogApp.AppPropertyCenter
|
propCenter
|
private static Stream.Port |
TEST_PED_ATTR_RECV_PORT
|
Constructor and Description |
---|
PedestrianAttrRecogAppTest()
|
Modifier and Type | Method and Description |
---|---|
private void |
checkTopic(String topic)
|
private void |
init(String[] args)
|
static void |
main(String[] args)
|
private void |
testAttrRecogApp()
|
private static final Stream.Port TEST_PED_ATTR_RECV_PORT
private org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer
private org.apache.kafka.clients.consumer.KafkaConsumer<String,byte[]> consumer
private ConsoleLogger logger
private PedestrianAttrRecogApp.AppPropertyCenter propCenter
public static void main(String[] args)
private void checkTopic(String topic)
private void init(String[] args) throws ParserConfigurationException, IOException, SAXException, URISyntaxException