Wir haben doch keine Zeit_

Fast Data und IoT

Jens Deters @jerady

Jochen Mader @codepitbull

!

"

# $

%

&

'()*�+

,

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

!

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

! ! ! ! ! ! ! ! !

#####

#####

#####

#####

#####

#####

#####

#####

!

-

MQTT

-.

-.

MQTT REACTIVE STREAMS KAFKA

Ingestion

Subscriber Subscription Publisher

create

cancel

next

subscribe

Processor

finished

Kafka

Broker

Topic1Topic1:Partition1

Segment1Segment2

SegmentN…

Topic1:Partition2

Segment1Segment2

SegmentN…

Topic2Topic2:Partition1

Segment1Segment2

SegmentN…

Topic2:Partition2

Segment1Segment2

SegmentN…

Topic2:Partition3

Segment1Segment2

SegmentN…

MQTT/topic1

group 1

consumer1

consumer2

consumer3broker1

broker2

broker3

MQTT/topic2

group 2

consumer4

consumer5

-.

SPARK

Digestion

-.

S3A / HDFS / Cassandra / …

Persistence

DEMO

?