Java项目使用Kafka
社区干货
Kafka 消息传递详细研究及代码实现|社区征文
## 背景新项目涉及大数据方面。之前接触微服务较多,趁公司没反应过来,赶紧查漏补缺。Kafka 是其中之一。Apache Kafka 是一个开源的分布式事件流平台,可跨多台计算机读取、写入、存储和处理事件,并有发布和订阅事... Java 实现 Kafka 消息发送分为直接、同步、异步发送。其中直接发送无回调,同步发送有阻塞,故生产环境多用异步发送。```Properties properties = new Properties();// 建立与 Kafka 群集的初始连接的主机/端...
Logstash 如何通过 Kafka 协议消费 TLS 日志
sasl_jaas_config => ""org.apache.kafka.common.security.plain.PlainLoginModule required username='${projectID}' password='${AK}#${SK}';" }}output { stdout {}}```强烈建议不要把 AccessKey ID 和 AccessKey Secret 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全, 建议使用 `jaas_path` 参数配置,示例如下```Javajaas_path => "/usr/share/logstash/conf...
消息队列选型之 Kafka vs RabbitMQ
以可水平扩展和高吞吐率而被广泛使用。目前越来越多的开源分布式处理系统如 Cloudera、Apache Storm、Spark、Flink 等都支持与 Kafka 集成。* **RocketMQ** 是阿里开源的消息中间件,目前已经捐献个 Apache 基金会,它是由 Java 语言开发的,具备高吞吐量、高可用性、适合大规模分布式系统应用等特点,经历过双十一的洗礼,实力不容小觑。* **Pulsar** 是 Apache 软件基金会的顶级项目,是下一代云原生分布式消息流平台,集消息、存...
聊聊 Kafka:Topic 创建流程与源码分析 | 社区征文
## 一、Topic 介绍Topic(主题)类似于文件系统中的文件夹,事件就是该文件夹中的文件。Kafka 中的主题总是多生产者和多订阅者:一个主题可以有零个、一个或多个向其写入事件的生产者,以及零个、一个或多个订阅这些事... .toMap.asJava newTopic.configs(configsMap) // 调用 adminClient 创建 Topic val createResult = adminClient.createTopics(Collections.singleton(newTopic), ne...
特惠活动
Java项目使用Kafka-优选内容
Java项目使用Kafka-相关内容
SASL_SSL 接入点 SCRAM 机制收发消息
1 安装 Java 依赖库在 Java 项目的 pom.xml 中添加相关依赖。此处以 Kafka 2.2.2 版本为例。 XML org.apache.kafka kafka-clients 2.2.2 org.slf4j slf4j-log4j12 1.7.6 2 添加配置文件创建消息队列 Kafka版配置文件 config.properties。配置文件字段的详细说明,请参考配置文件。 说明 SCRAM 机制下,应使用具备对应 Topic 访问权限的 SCRAM 用户进行 SASL 认证。获取用户名及密码的方式请参考2 收集连接信息。 通过 SASL_SSL 接...
通过 Kafka 消费火山引擎 Proto 格式的订阅数据
python pip install kafka-pythonpython pip install protobufpython pip install python-snappy Java 安装 Java,需使用 Java 1.8 或以上版本。您可以执行 java -version 查看 Java 版本。 安装 maven,需使用 Maven 3.8 或以上版本。 您可以执行 mvn -version 查看 Maven 版本。 在 IDEA 软件,单击 Create New Project 创建一个 Project。 在新建的 Project 中的项目对象模型文件 pom.xml 中添加以下依赖,本示例以 Kafka 2...
通过 Kafka 消费 Canal Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 Kafka 客户端消费 Canal Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go、Java 和 Python 语言消费 Canal Proto 格式的数据。 前提条件已... 操作步骤下载和编译 ProtoBuf在运行对应语言的 demo 时,需要先根据以下操作步骤完成 Protocol Buffers(也称 ProtoBuf)文件的下载及编译。 说明 本文以火山引擎定义的 ProtoBuf 为例。 下载 ProtoBuf 文件。 将下...
Kafka 生产者最佳实践
本文档以 Confluent 官方的 Java 版本 SDK 为例介绍 Kafka 生产者和消费者的使用建议。推荐在使用消息队列 Kafka版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消息顺序性火山引擎 Kafka... 即调用 send 方法写入消息时,实际消息仅仅是写入本地缓存中,实际并未发送到服务端。消息会在本地缓存中根据分区做一次消息聚合,之后由异步发送线程扫描将聚合后的消息发送到服务端中。send 方法仅为写入缓存,不代表...
Java SDK 概述
火山引擎 Volcengine SDK for Java 封装了消息队列 Kafka版的常用 OpenAPI 接口,您可以通过消息队列 Kafka版 Volcengine SDK 调用服务端 API,实现创建实例、创建 Topic 等功能。 版本说明火山引擎 Volcengine SDK ... Java SDK 源码请参考 Volcengine Java SDK 源码。 示例代码Volcengine SDK 已对接 API Explorer,在使用 API Explorer 调试接口时,页面会同步显示对应请求的 SDK 示例,您可以参考 SDK 示例或直接下载完整工程,实现对...
Kafka 消费者最佳实践
本文档以 Confluent 官方 Java 版本客户端 SDK 为例,介绍使用火山引擎 Kafka 实例时的消费者最佳实践。 广播与单播在同一个消费组内部,每个消息都预期仅仅只被消费组内的某个消费者消费一次,因而使用同一个消费组的... 因而使用不同消费组的不同消费者之间,即可实现消息的广播消费。 幂等性消息是否被客户端消费,在服务端的认知中,仅和保存在服务端的消费位点有关。而消费位点是由消费者调用相关 API 从而记录到服务端,那么在客户端...
准备工作
在运行 Java SDK 代码收发消息前,您需按照本文提供的步骤来准备开发环境。 开发环境软件 版本要求 JDK 1.8 或以上版本。 Maven 2.5 或以上版本。 操作步骤 1 创建资源接入消息队列 Kafka版收发消息前,需要先... 详细操作步骤请参考创建用户。说明 通过默认接入点收发消息时,无需创建 SASL 用户、通过 SASL 用户进行鉴权。 2 收集连接信息调用相关接口类收发消息时需要在代码中配置连接信息等参数,收发消息前请参考以下步骤...
使用 Kafka 协议上传日志
日志服务支持通过 Kafka 协议上传和消费日志数据,基于 Kafka 数据管道提供完整的数据上下行服务。使用 Kafka 协议上传日志功能,无需手动开启功能,无需在数据源侧安装数据采集工具,基于简单的配置即可实现 Kafka Producer 采集并上传日志信息到日志服务。日志服务提供基于 Java 和 Go 语言的示例项目供您参考,详细信息请参考示例。通过 Kafka 协议采集日志时,对于合法的 JSON 格式日志,日志服务会正常解析为 Key-Value 对;对于不合...
通过 Kafka 协议消费日志
2 小时后或关闭 Kafka 协议消费功能时会被删除。但有效期内的日志数据可以被持续消费。 支持通过标准的开源 Kafka Java SDK 进行日志数据消费,消费日志的示例代码请参考示例代码。也可以使用 Spark Streaming 或 Flink 的 Kakfa 插件对接日志服务,详细说明请参考通过 Spark Streaming 消费日志和通过 Flink 消费日志。 为保证日志传输的安全性,必须使用 SASL_SSL 连接协议。对应的用户名为日志服务项目 ID,密码为火山引擎账号密...
