hello-streams's Introduction

1. Wikipedia Edits

a) Kafka Stream implementation
b) Apache Flink implementation
c) Apache Beam implementation

Start local cluster

docker-compose up

Create Topics

docker exec -it kafka_broker_1 /opt/kafka/current/bin/kafka-topics.sh --zookeeper localhost --create --topic wikipedia-raw --replication-factor 1 --partitions 4

$ ./bin/kafka-topics.sh --zookeeper localhost --create --topic wikipedia-parsed --replication-factor 1 --partitions 4 $ ./bin/kafka-topics.sh --zookeeper localhost --create --topic wikipedia-streams-wikipedia-edits-by-user-changelog
--replication-factor 1 --partitions 4

2. Recursive Web Crawler Demo

Web Crawler done as a recursive stream processor

Topology

                                     URL Processor
                             +--------------------------+
                             |                          |
                         +-> | ? > Fetch > Clean > Page |
                        /    |                          |
                       /     +--------------------------+
      ~~~~~~~~~~~~~~  /      |                          | - INPUT: URL
+--->   URL Stream   +-----> | ? > Fetch > Clean > Page | -=STATE: Set of URLs
|     ~~~~~~~~~~~~~~  \      |                          |   already requested
|                      \     +--------------------------+ - OUTPUT: PAGE
|                       \    |                          |
|                        +-> | ? > Fetch > Clean > Page |
|                            |                          |
|                            +------------+-------------+
|                                         |
|                                         |
|           +-----------------------------+
|           |
|           |                     PAGE Processor
|           |                +---------------------+
|           |                | ? Already Crawled   |
|           |                |  > Extract Links    |
|           |            +-> |   > Produce URLs    |
|           v           /    |    > Produce Assets |  - INPUT: PAGE
|     ~~~~~~~~~~~~~~~  /     |                     |  - STATE: Set of Content
|       PAGE Stream   +      +---------------------+    Hashes already crawled
|     ~~~~~~~~~~~~~~~  \     | ? Already Crawled   |  - OUTPUT 1: URLs       
|                       \    |  > Extract Links    |  - OUTPUT 2: ASSETS
|                        +-> |   > Produce URLs    |
|                            |    > Produce Assets |
|                            |                     |
|                            +--------+-+----------+
|                                     | |
+-------------------------------------+ |
                                        |
             +--------------------------+
             |
             |
             v
     ~~~~~~~~~~~~~~~~
       ASSET Stream   +-------->   PRINT
     ~~~~~~~~~~~~~~~~

Recommend Projects