Kafka 基础实战 :消费者和生产者实例 VIP

成为vip会员,免费看所有精品课程
  • 目录

    目录 收起>

    本课程首先会讲解 Kafka 消费者和生产者的两种编程模型,然后展示用 Python 和 Java 编写的消费者和生产者程序的实际效果,之后讲解用 Python 和 Java 编写 Kafka 消费者和生产者程序的步骤和实际代码,最后,总结使用 Kafka 客户端编程的基本知识点和一些参数调优的过程。

    1.Kafka消费者编程模型 00:15:08

    本课时主要对 Kafka 消费者的两种编程模型(按分区消费和按组消费)进行介绍,然后会使用伪代码讲解这两种编程模型。

    2.Kafka 消费者的 Python 和 Java 客户端实现 00:25:26

    本课时首先会选择 Kafka-Python 包进行 Kafka 消费者两种模型的实现,其次会使用 Java 实现 Kafka 消费者的两种模型,之后会讲解消费者的一些调优参数,最后会在集群演示效果。

    3.Kafka 生产者编程模型 00:11:58

    本课时主要对 Kafka 生产者的两种编程模型(同步发送和异步发送)进行介绍,然后会使用伪代码讲解这两种编程模型

    4.Kafka 生产者的 Python 和 Java 客户端实现 00:22:37

    本课时首先会选择 Kafka-python 包进行 Kafka 生产者两种模型的实现,其次会使用 Java 实现 Kafka 生产者的两种模型,之后会讲解生产者的一些调优参数,最后会在集群演示效果
  • 提问

    提交问题
  • 下载

  • 线路

    视频太卡?试试切换线路 √ 线路1 √ 线路2
  • 收藏

    收藏课程
  • 分享

连播

连续播放

关灯

关灯模式
视频加载太慢?

我们有两条线路可以选择,试试切换线路吧

Kafka 基础实战 :消费者和生产者实例

4课时,75分钟2015-09-18
Scoot
Scoot

极客学院签约布道师

课程背景:
前面一个课程讲解了 Kafka 的一些入门知识,Python 和 Java 是大数据领域用得比较多的两种语言,所以本课时将带领大家用这两种客户端语言进行 Kafka 生产者和消费者代码的编写,毕竟大家使用 Kafka 集群是想发送消息到 Kafka ,然后从 Kafka 取出消息。

核心内容:
1.Kafka 消费者的两种模型;
2.Kafka 生产者的两者模型;
3.Python 的 Kafka 消费者和生产者代码的编写;
4.Java 的 Kafka 消费者和生产者代码的编写;
5.Kafka 消费者和生产者的参数调优。

软件环境:Linux服务器至少一台;kafka-python0.93.zip、kafka2.9.2_0.8.1

是否提供资料:

课程等级:初级

适合人群:
做数据开发;对大数据开发有兴趣;需要进行大量日志传输;并且有 Kafka 基础的人群
  • 技术问答
  • 1

    Kafka消费者编程模型

    15:08

    本课时主要对 Kafka 消费者的两种编程模型(按分区消费和按组消费)进行介绍,然后会使用伪代码讲解这两种编程模型。

  • 2

    Kafka 消费者的 Python 和 Java 客户端实现

    25:26

    本课时首先会选择 Kafka-Python 包进行 Kafka 消费者两种模型的实现,其次会使用 Java 实现 Kafka 消费者的两种模型,之后会讲解消费者的一些调优参数,最后会在集群演示效果。

  • 3

    Kafka 生产者编程模型

    11:58

    本课时主要对 Kafka 生产者的两种编程模型(同步发送和异步发送)进行介绍,然后会使用伪代码讲解这两种编程模型

  • 4

    Kafka 生产者的 Python 和 Java 客户端实现

    22:37

    本课时首先会选择 Kafka-python 包进行 Kafka 生产者两种模型的实现,其次会使用 Java 实现 Kafka 生产者的两种模型,之后会讲解生产者的一些调优参数,最后会在集群演示效果

相关课程

  • kafka的初认识

    本课程首先对kafka的使用背景(kafka是什么,能够用来做什么,为什么要使用它)进行简单的介绍,然后会介绍kafka的一些基本概念,其后边演示边讲解zookeeper集群和kafka集群的搭建,最后会对kafka集群的一些配置参数进行详细的解释。

    4课时 79分钟
    初级
    17306人学习
  • 高级抽象元语 Trident

    本课程将会讲解 Storm 实时处理系统当中一个重要的概念分支:Trident——高级抽象元语,在讲解了 Trident 的概念之后,将辅以实战演练编写基于 Trident 实现的 Storm 实时处理系统实例。

    3课时 38分钟
    中级
    4239人学习
  • Kafka 用户日志上报实时统计之分析与设计

    本课程以用户实时上报日志案例为基础,带着大家对一个 Kafka 项目的各个环节做详细的介绍和分析,从而对项目的整体设计做合理的规划,让大家能通过本课程掌握 Kafka 项目的分析与设计。

    4课时 17分钟
    中级
    6002人学习
  • HBase 数据的导入

    本课程将介绍如何利用 HBase 提供的管理工具批量的将外部数据导入到 HBase 数据库中。

    3课时 35分钟
    中级
    5471人学习