Apache Kafka教程 第2页

2020-02-13半瓶木阅读(975)评论(0)赞(0)

Apache Kafka是一个分布式系统，其中的主题在各个节点之间进行分区和复制。它还支持容错能力和耐用性。可能会有故障排除的机会。因此，需要管理和监视不同的Kafka活动。各种Kafka监视工具用于监视和显示纠正措施。 在Kafka监视下...

2020-02-13半瓶木阅读(880)评论(0)赞(0)

Apache Kafka是一个分布式系统，其中的主题在各个节点之间进行分区和复制。它还支持容错能力和耐用性。可能会有故障排除的机会。因此，需要管理和监视不同的Kafka活动。各种Kafka监视工具用于监视和显示纠正措施。 在Kafka监视下...

2020-02-13半瓶木阅读(4611)评论(0)赞(0)

本文概述 创建记录器 创建消费者属性 创造消费者 订阅消费者 轮询新数据 读取消费者组中的数据 在上一节中，我们学习了用Java创建生产者。在本节中，我们将学习在Java中实现Kafka使用者。 要创建使用者，需要执行以下步骤： 创建记录器...

2020-02-13半瓶木阅读(5285)评论(0)赞(0)

本文概述 无Key生产者 带Key生产者 无Key生产者 在上一节中，我们了解了生产者如何将数据发送到Kafka。为了更深入地了解数据，即数据是否正确生成，在何处生成，有关其偏移量和分区值等。让我们了解更多信息。 为了执行回调，用户需要实现...

2020-02-13半瓶木阅读(1968)评论(0)赞(0)

本文概述 创建Java生产者 创建生产者属性 创建生产者记录 发送数据 在上一节中，我们学习了创建Kafka项目的基本步骤。现在，在用Java创建Kafka生产者之前，我们需要定义基本的Project依赖项。在我们的项目中，将需要两个依赖项...

2020-02-13半瓶木阅读(3667)评论(0)赞(0)

本文概述 创建Kafka项目 先决条件：应在系统上安装java8。 请按照以下演示的步骤在系统上安装IntelliJ IDEA： 步骤1：使用Jetbrains网站或使用以下链接下载IntelliJ IDEA： ‘https:/...

2020-02-13半瓶木阅读(2752)评论(0)赞(1)

本文概述 读取完整消息 在本部分中，用户将学习消费者如何消费或阅读Kafka主题中的消息。 使用者采取了以下步骤来消费来自主题的消息： 步骤1：首先启动zookeeper和kafka服务器。 步骤2：在命令行中输入命令：“ kafka-co...

2020-02-13半瓶木阅读(1385)评论(0)赞(0)

本文概述 带Key的消费者 有关消费者组的更多信息 重置偏移 通常，Kafka消费者属于特定的消费者组。使用者组基本上代表了应用程序的名称。为了使用使用者组中的消息，使用了“ -group”命令。 让我们看看消费者将如何消费来自Kafka主...

2020-02-13半瓶木阅读(785)评论(0)赞(0)

本文概述 Kafka编程简介 什么是Maven？ Kafka编程简介 在上一节中，我们学习了使用命令行界面创建主题，写入主题以及从主题中读取内容。生产者和使用者用来从/向Kafka主题读取/写入消息的命令。 在本部分中，用户将再次通过Jav...

2020-02-13半瓶木阅读(2686)评论(0)赞(0)

本文概述 Kafka控制台生产者 带Key生产者 什么时候不存在主题？ 描述新主题 更改默认值 Kafka控制台生产者 为了将数据发送到Kafka主题，需要生产者。生产者的作用是向Kafka主题发送或写入数据/消息。 在本节中，我们将学习生...