work
- Banking system -> generate log file.
- parsing log file and generate event -> kafka publish to 'bank.events' topic
- build kafka topology -> source, storeProcess, ruleProcess, sink
#command
1.zookeeper-server-start /usr/local/Cellar/kafka/0.11.0.0/libexec/config/zookeeper.properties
2.kafka-server-start /usr/local/Cellar/kafka/0.11.0.0/libexec/config/server.properties
3.kafka-console-consumer --bootstrap-server localhost:9092 \
--topic fds.detections \
--from-beginning \
--property print.key=true \
--property print.value=true \
--property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \
--property value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
4.kafka-console-consumer --bootstrap-server localhost:9092 \
--topic bank.events \
--from-beginning \
--property print.key=true \
--property print.value=true \
--property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \
--property value.deserializer=org.apache.kafka.common.serialization.StringDeserializer