Apache Kafka Quick Start Guide电子书

Title page

Copyright and Credits

Apache Kafka Quick Start Guide

Dedication

About Packt

Why subscribe?

Packt.com

Contributors

About the author

About the reviewer

Packt is searching for authors like you

Preface

Who this book is for

What this book covers

To get the most out of this book

Download the example code files

Conventions used

Get in touch

Reviews

Configuring Kafka

Kafka in a nutshell

Kafka installation

Kafka installation on Linux

Kafka installation on macOS

Confluent Platform installation

Running Kafka

Running Confluent Platform

Running Kafka brokers

Running Kafka topics

A command-line message producer

A command-line message consumer

Using kafkacat

Summary

Message Validation

Enterprise service bus in a nutshell

Event modeling

Setting up the project

Reading from Kafka

Writing to Kafka

Running the processing engine

Coding a validator in Java

Running the validation

Summary

Message Enrichment

Extracting the geographic location

Enriching the messages

Extracting the currency price

Enriching with currency price

Running the engine

Extracting the weather data

Summary

Serialization

Kioto, a Kafka IoT company

Project setup

The constants

HealthCheck message

Java PlainProducer

Running the PlainProducer

Java plain consumer

Java PlainProcessor

Running the PlainProcessor

Custom serializer

Java CustomProducer

Running the CustomProducer

Custom deserializer

Java custom consumer

Java custom processor

Running the custom processor

Summary

Schema Registry

Avro in a nutshell

Defining the schema

Starting the Schema Registry

Using the Schema Registry

Registering a new version of a schema under a – value subject

Registering a new version of a schema under a – key subject

Registering an existing schema into a new subject

Listing all subjects

Fetching a schema by its global unique ID

Listing all schema versions registered under the healthchecks–value subject

Fetching version 1 of the schema registered under the healthchecks-value subject

Deleting version 1 of the schema registered under the healthchecks-value subject

Deleting the most recently registered schema under the healthchecks-value subject

Deleting all the schema versions registered under the healthchecks–value subject

Checking whether a schema is already registered under the healthchecks–key subject

Testing schema compatibility against the latest schema under the healthchecks–value subject

Getting the top-level compatibility configuration

Globally updating the compatibility requirements

Updating the compatibility requirements under the healthchecks–value subject

Java AvroProducer

Running the AvroProducer

Java AvroConsumer

Java AvroProcessor

Running the AvroProcessor

Summary

Kafka Streams

Kafka Streams in a nutshell

Project setup

Java PlainStreamsProcessor

Running the PlainStreamsProcessor

Scaling out with Kafka Streams

Java CustomStreamsProcessor

Running the CustomStreamsProcessor

Java AvroStreamsProcessor

Running the AvroStreamsProcessor

Late event processing

Basic scenario

Late event generation

Running the EventProducer

Kafka Streams processor

Running the Streams processor

Stream processor analysis

Summary

KSQL

KSQL in a nutshell

Running KSQL

Using the KSQL CLI

Processing data with KSQL

Writing to a topic

Summary

Kafka Connect

Kafka Connect in a nutshell

Project setup

Spark Streaming processor

Reading Kafka from Spark

Data conversion

Data processing

Writing to Kafka from Spark

Running the SparkProcessor

Summary

Other Books You May Enjoy

Leave a review - let other readers know what you think