Topics

• Getting started with apache-kafka
• Getting started with gson
• Using Gson with JAX-RS (RESTful web services)
• Getting started with apache-flink
• Python Driver
• Table API
• Producer/Consumer in Java
• kafka console tools
• Custom Serializer/Deserializer
• Consume data from Kafka
• How to define a custom (de)serialization schema
• Cassandra keys
• Converting between BSON and JSON
• Checkpointing
• Savepoints and externalized checkpoints
• logging
• Access Maven informations in code

Examples

• Installation
• JAX-RS provider to use Gson
• Serialization and deserialization
• Arrays
• Overview and requirements
• Convert String to JsonObject without POJO
• Using GSON with inheritance
• PyMongo queries
• Update all documents in a collection using PyMongo
• Local runtime setup
• Flink Environment setup
• WordCount - Table API
• WordCount
• WordCount - Streaming API
• Maven dependencies
• Simple aggregation from a CSV
• Join tables example
• Using external sinks
• SimpleConsumer (Kafka >= 0.9.0)
• SimpleProducer (kafka >= 0.9)
• Introduction
• kafka-topics
• kafka-console-producer
• kafka-console-consumer
• kafka-simple-consumer-shell
• kafka-consumer-groups
• Gson (de)serializer
• KafkaConsumer example
• Fault tolerance
• Built-in deserialization schemas
• Kafka partitions and Flink parallelism
• Custom Schema Example
• Partition key, clustering key, primary key
• The PRIMARY KEY syntax
• Key ordering and allowed queries
• Using json_util
• Using python-bsonjs
• Using the json module with custom handlers
• Configuration and setup
• Testing checkpoints
• Savepoints: requirements and preliminary notes
• Savepoints
• Externalized checkpoints (Flink 1.2+)
• Using a logger in your code
• Logging configuration
• Using different configuration(s) for each application
• Flink-on-Yarn workaround: get logs in real-time with rsyslog
• Getting the version number from within a jar
• Keeping a properties file in sync using maven's property filtering mecanism
• Reading a pom.xml at runtime using maven-model plugin