Log In
Or create an account -> 
Imperial Library
  • Home
  • About
  • News
  • Upload
  • Forum
  • Help
  • Login/SignUp

Index
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
  • ← Prev
  • Back
  • Next →
  • ← Prev
  • Back
  • Next →

Chief Librarian: Las Zenow <zenow@riseup.net>
Fork the source code from gitlab.

This is a mirror of the Tor onion service:
http://kx5thpx2olielkihfyo4jgjqfb7zx7wxr3sd4xzt26ochei4m6f7tayd.onion