Kafka Java编程

Kafka 编程简介

在上一节中，我们学习了创建主题，写入一个topic ，并使用命令行界面阅读该主题。生产者和消费者用于从/向Kafka主题读取/写入消息的命令。

在本节中，用户将再次学习通过java代码读取和写入Kafka主题的消息。期望用户具有 Java 的基本知识。

使用 Apache Kafka 时需要满足的要求很少:

• IDE 工具，例如 Notepad、Eclipse、IntelliJ IDEA 等。
• 需要 JDK 1.8
• 构建工具，例如 Gradle、Maven3 等。

在本教程中，我们将使用 IntelliJ IDEA 和 Maven3 构建工具来学习 Apache Kafka。

什么是 Maven？

maven 是一种主要用于 Java 项目的构建工具。尽管如此，它也可以用于构建和处理用其他语言编写的项目，例如 Scala、Ruby 等。Maven 专注于项目的构建方式以及它的依赖项。 Maven 允许用户将存储库添加到 Java 代码中。 Maven 存储库将帮助 Kafka 用户在 Kafka 上开发他们的项目。

要了解有关 Maven 的更多信息，请访问我们的"Maven 教程"。

在转到下一部分，即安装部分，用户应该知道以下内容:

Group Id: 它是我们的应用程序的名称，应该按照java包命名创建规则。组 ID 用于唯一标识每个应用程序或组。

工件 ID: 工件 ID 是 jar 文件的名称。 Maven 会将我们的应用程序打包到这个具有用户指定名称的 jar 文件中。

Version: 它是用户为其应用程序或组 ID 创建的版本号。

先决条件: 系统上应安装 java8、按照以下演示步骤安装 IntelliJ系统上的 IDEA:步骤 1: 使用 Jetbrains 网站或使用以下链接下载 IntelliJ IDEA:'https://w ...