|
所在平台: Udemy |
课程主页: https://www.udemy.com/course/how-to-create-go-tcp-server-and-kafka-golang/
课程评论：没有评论
**课程名称：** 使用Kafka Stream构建Golang TCP服务器应用 **课程概述：** 本课程将深入探索Apache Kafka——一个强大的分布式流处理平台。Kafka具备三大核心能力： 1. **发布与订阅：** 允许用户像消息队列一样发布和订阅记录流。 2. **持久化存储：** 以容错且持久化的方式存储记录流。 3. **实时处理：** 在数据流发生时进行实时处理。 Kafka广泛应用于两大场景： * **构建实时流数据管道：** 可靠地在系统或应用之间传输数据。 * **构建实时流应用：** 对数据流进行转换或响应。 课程将从底层原理入手，全面解析Kafka的工作机制。 **核心概念：** * **集群：** Kafka在一个或多个服务器上运行，可以跨越多个数据中心。 * **主题（Topics）：** Kafka将记录流存储在名为“主题”的分类中。 * **记录（Records）：** 每条记录包含一个键（key）、一个值（value）和时间戳（timestamp）。 **技术栈：** * **Apache Kafka：** 一个开源的分布式事件存储和流处理平台，用Java和Scala编写，旨在提供高吞吐量、低延迟的实时数据处理能力。 * **Confluent Go Client for Kafka：** Confluent提供的Go客户端，支持使用Go语言向Kafka主题发送（Producer）和接收（Consumer）数据。 **学习目标：** 通过本课程，学员将能够： * 理解Kafka作为分布式流处理平台的原理。 * 掌握Kafka的核心概念，如集群、主题和记录。 * 了解Kafka在数据管道和实时应用中的作用。 * 学习如何使用Confluent的Go客户端构建Golang TCP服务器应用，与Kafka进行交互。
Apache Kafka is a distributed streaming platform. What exactly does that mean?A streaming platform has three key capabilities:Publish and subscribe to streams of records, similar to a message queue or enterprise messaging system.Store streams of records in a fault-tolerant durable way.Process streams of records as they occur.Kafka is generally used for two broad classes of applications:Building real-time streaming data pipelines that reliably get data between systems or applicationsBuilding real-time streaming applications that transform or react to the streams of dataTo understand how Kafka does these things, let's dive in and explore Kafka's capabilities from the bottom up.First a few concepts:Kafka is run as a cluster on one or more servers that can span multiple datacenters.The Kafka cluster stores streams of records in categories called topics.Each record consists of a key, a value, and a timestamp.Apache Kafka is a distributed event store and stream-processing platform. It is an open-source system developed by the Apache Software Foundation written in Java and Scala. The project aims to provide a unified, high-throughput, low-latency platform for handling real-time data feeds.Confluent develops and maintains a Go client for Apache Kafka that offers a producer and a consumer. This library provides capabilities to produce to and consume from Kafka topics using Go.
