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