srcmini

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

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

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

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

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

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

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

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

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

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

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

本文概述 主题已存在 关于主题的更多信息 在本节中，用户将学习使用Windows上的命令行界面（CLI）创建主题。 可以使用以下步骤创建主题： 第1步：首先，请确保同时启动Zookeeper和Kafka服务器。 步骤2：在控制台上输入“ k...

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

本文概述 设定路径 在Linux上启动Zookeeper Server 先决条件：应该在系统上安装Java8。 可以使用以下步骤在Linux系统上安装Apache Kafka： 步骤1：检查Java版本。它应该与版本8一起安装，因为Kafk...

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

先决条件：应在系统上安装版本8的Java。 要下载最新版本的Apache Kafka（或根据需要），将使用以下步骤： 步骤1：打开Apache Foundation的官方网站，或使用链接：https://kafka.apache.org/d...

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

本文概述 在Windows上安装Apache Kafka 设置Kafka目录路径 安装Zookeeper Windows，macOS以及Linux环境都支持Apache Kafka。每个操作系统都有其自己的步骤/过程来安装Apache Ka...

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

我们已经学习了Apache Kafka的基本概念。这些基本概念，例如主题，分区，生产者，消费者等，共同构成了Kafka体系结构。 由于不同的应用程序相应地设计了Kafka的体系结构，因此需要以下基本部分来设计Apache Kafka体系结构...