Topics, Partitions, and APIs oh my! This episode we’re getting further into how Apache Kafka works and its use cases. Also, Allen is staying dry, Joe goes for broke, and Michael (eventually) gets on the right page.
The full show notes are available on the website at https://www.codingblocks.net/episode236
News
Thanks for the reviews! angingjellies and Nick BrookerPlease leave us a review! (/review)Atlanta Dev Con is coming up, on September 7th, 2024 (www.atldevcon.com)Kafka Topics
They are partitioned – this means they are distributed (or can be) across multiple Kafka brokers into “buckets”New events written to Kafka are appended to partitionsThe distribution of data across brokers is what allows Kafka to scale so well as data can be written to and read from many brokers simultaneouslyEvents with the same key are written to the same partition as the original eventKafka guarantees reads of events within a partition are always read in the order that they were writtenFor fault tolerance and high availability, topics can be replicated…even across regions and data centersNOTE: If you’re using a cloud provider, know that this can be very costly as you pay for inbound and outbound traffic across regions and availability zonesTypical replication configurations for production setups are 3 replicasKafka APIS
Admin API – used for managing and inspecting topics, brokers, and other Kafka objectsProducer API – used to write events to Kafka topicsConsumer API – used to read data from Kafka topicsKafka Streams API – the ability to implement stream processing applications/microservices. Some of the key functionality includes functions for transformations, stateful operations like aggregations, joins, windowing, and moreIn the Kafka streams world, these transformations and aggregations are typically written to other topics (in from one topic, out to one or more other topics)Kafka Connect API – allows for the use of reusable import and export connectors that usually connect external systems. These connectors allow you to gather data from an external system (like a database using CDC) and write that data to Kafka. Then you could have another connector that could push that data to another system OR it could be used for transforming data in your streams applicationThese connectors are referred to as Sources and Sinks in the connector portfolio (confluent.io)Source – gets data from an external system and writes it to a Kafka topicSink – pushes data to an external system from a Kafka topicUse Cases
Message queue – usually talking about replacing something like ActiveMQ or RabbitMQ
** Message brokers are often used for responsive types of processing, decoupling systems, etc. – Kafka is usually a great alternative that scales, generally has faster throughput, and offers more functionalityWebsite activity tracking – this was one of the very first use cases for Kafka – the ability to rebuild user actions by recording all the user activities as events How and why Kafka was developed (LinkedIn)Typically different activity types would be written to different topics – like web page interactions to one topic and searches to anotherMetrics – aggregating statistics from distributed applicationsLog aggregation – some use Kafka for storage of event logs rather than using something like HDFS or a file server or cloud storage – but why? Because using Kafka for the event storage abstracts away the events from the filesStream processing – taking events in and further enriching those events and publishing them to new topicsEvent sourcing – using Kafka to store state changes from an application that are used to replay the current state of an object or systemCommit log – using Kafka as an external commit log is a way for synchronizing data between distributed systems, or help rebuild the state in a failed systemTip of the Week
Rémi Gallego is a music producer who makes music under a variety of names like The Algorithm and Boucle Infini, almost all of it is instrumental Synthwave with a hard-rock edge. They also make a lot of video game music, including 2 of my favorite game soundtracks of all time “The Last Spell” and “Hell is for Demons” (YouTube)Did you know that the Kubernetes-focused TUI we’ve raved about before can be used to look up information about other things as well, like :helm and :events. Events is particularly useful for figuring out mysteries. You can see all the “resources” available to you with “?”. You might be surprised at everything you see (pop-eye, x-ray, and monitoring)WarpStream is an S3 backed, API compliant Kafka Alternative. Thanks MikeRg! (warpstream.com)Cloudflare’s trillion message Kafka setup, thanks Mikerg! (blog.bytebytego.com)Want the power and flexibility of jq, but for yaml? Try yq! (gitbook.io)Zenith is terminal graphical metrics for your *nix system written in Rust, thanks MikeRg! (github.com)8 Big (O)Notation Every Developer should Know (medium.com)Another Git cheat sheet (wizardzines.com)
View all episodes
