Pulsar Client Go 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
Pulsar Client Go 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
Pulsar Client Go 获得 2020 年度 OSC 中国开源项目评选「最佳人气项目」 !
Pulsar Client Go 获得 2020 年度 OSC 中国开源项目评选「最佳人气项目」「最积极运营项目」 !
Pulsar Client Go 获得 2020 年度 OSC 中国开源项目评选「最积极运营项目」 !

软件简介

由于 Go 语言与生俱来的优势以及 Go 社区的不断壮大,Pulsar 社区对 Go Client 的呼声很高。pulsar-client-go 是一个使用 Go 语言编写的 Pulsar  Go Client 库,项目目标在于创建纯 Go 语言编写的客户端,并且不依赖任何 C++ 库文件。用户可以通过 Pulsar Go 客户端在 Go(又称 Golang)中创建 Pulsar 生产者、消费者和 reader。在 Go 客户端中,生产者、消费者和 reader 中的所有方法都是线程安全的。

Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存储分离架构设计,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐、低延时及高可扩展流数据存储特性。

此前,Pulsar 社区向大家提供了基于 CPP 封装的 pulsar-client-go,但是 CGO 存在诸多问题,且性能易损耗,使得 Pulsar 难以更好地支持 Go 社区。这促使我们基于原生的 Go 语言来重写整个 Go Client,旨在替换原来的 CGO client,从而更好地支持 Pulsar在 Go 社区的应用和集成 。

使用环境要求:Go 1.11 以上版本

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (0)

加载中
更多评论
发表了资讯
03/08 17:03

Pulsar Go Client 0.4.0 发布

Pulsar Client Go 是 Apache Pulsar 的 Go 语言客户端。近期,社区发布 Pulsar Client Go 0.4.0 版本。 新特性 支持在 producer 端发送超时 添加内部发布延迟指标 添加基于 key_batch 的批处理逻辑 添加错误标签以发布错误指标 将const 客户标签添加到指标 等等 性能提升 将go-keyring更新到v1.1.6,以删除MacOS Catalina +上的警告 在消息路由期间减少时钟读取时间 修复丢弃未确认的消息 等等...

0
1
2020/11/18 10:33

Apache Pulsar Go Client 0.3.0 版本发布

Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台。 Pulsar Go Client 是分布式消息流平台 Apache Pulsar 的 Go 语言客户端,开发者可以通过 Pulsar Go 客户端在 Go 中创建 Pulsar 生产者、消费者和 reader。在 Go 客户端中,生产者、消费者和 reader 中的所有方法都是线程安全的。 近日,Pulsar Go Client 发布了 0.3.0 版本,在功能方面有很多改进: 支持在 Go 客户端中的 Key Shared 策略 在生产...

2
4
发表于服务端专区
2020/09/09 14:44

Apache Pulsar Go Client 0.2.0 版本更新

Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台。 Pulsar Go Client 是分布式消息流平台 Apache Pulsar 的 Go 语言客户端,开发者可以通过 Pulsar Go 客户端在 Go 中创建 Pulsar 生产者、消费者和 reader。在 Go 客户端中,生产者、消费者和 reader 中的所有方法都是线程安全的。近日,Pulsar Go Client 发布了 0.2.0 版本,在功能方面有很多改进: 在 pulsar-go-client 中支持 oauth2 认证 支持...

0
3
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
2020/07/01 10:32

[Pulsar-源码] Pulsar client初始化

文章目录 Pulsar client初始化过程 Producer 初始化 Pulsar client初始化过程 初始化Pulsar Producer和Consumer都需要先初始化Pulsar client。示例: PulsarClient client = PulsarClient.builder() .serviceUrl("pulsar://127.0.0.1:6650") .build(); 1 2 3 PulsarClient.builder() 会创建一个ClientBuilderImpl一个实例, 并用一个 ClientConfigurationData实例来初始化conf对象; .serviceUrl("pulsar://127.0.0.1:6650") 为c...

0
0
2019/10/17 17:00

Pulsar Kafka Client 简单介绍

🎙️阅读本文需要 5 分钟 为了方便 Kafka 用户使用 Pulsar,Pulsar 对 Kafka Client 做了一些封装,让 Kafka 用户更方便的使用 Pulsar。 本篇内容主要介绍 Kafka Client 如何将消息发送到 Pulsar, 并从 Pulsar 消费消息,以及如何使用 Pulsar Schema。 ⌨️ 引入依赖 <dependency> <groupId>org.apache.pulsar</groupId> <artifactId>pulsar-client-kafka</artifactId> <version>{project.version}</version></dependency...

0
0
2019/10/17 17:10

Pulsar Kafka Client 简单介绍

🎙️阅读本文需要 5 分钟 为了方便 Kafka 用户使用 Pulsar,Pulsar 对 Kafka Client 做了一些封装,让 Kafka 用户更方便的使用 Pulsar。 本篇内容主要介绍 Kafka Client 如何将消息发送到 Pulsar, 并从 Pulsar 消费消息,以及如何使用 Pulsar Schema。 ⌨️ 引入依赖 <dependency> <groupId>org.apache.pulsar</groupId> <artifactId>pulsar-client-kafka</artifactId> <version>{project.version}</version></dependency...

0
0
2020/11/20 07:20

【行业资讯】Apache Pulsar Go Client 0.3.0 版本发布

Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台。 Pulsar Go Client 是分布式消息流平台 Apache Pulsar 的 Go 语言客户端,开发者可以通过 Pulsar Go 客户端在 Go 中创建 Pulsar 生产者、消费者和 reader。在 Go 客户端中,生产者、消费者和 reader 中的所有方法都是线程安全的。 近日,Pulsar Go Client 发布了 0.3.0 版本,在功能方面有很多改进: 支持在 Go 客户端中的 Key Shared 策略 在生产...

0
0
发表于服务端专区
2020/06/18 16:12

pulsar起client客户端时(client,producer,consumer)各个配置选项的含义

producer 参考代码 // 构造生产者 this.producer = client.newProducer(Schema.BYTES) .producerName(judgeValue(“producerName”)) .topic(judgeValue(“topic”)) .batchingMaxMessages(Integer.parseInt(judgeValue(“batchingMaxMessages”))) .batchingMaxPublishDelay(Long.parseLong(judgeValue(“batchingMaxPublishDelay”)), TimeUnit.MILLISECONDS) .enableBatching(Boolean.getBoolean(judgeValue(“enableBatchin...

0
0
2020/05/27 14:50

Pulsar 2.5.0 之Java client

Pulsar 2.5.0 之Java client 官网原文标题《Pulsar Java client》 翻译时间:2020-02-14 官网原文地址:http://pulsar.apache.org/docs/en/client-libraries-java/ 译者:本文介绍如何使用javaClient创建生产者、消费者以及通过管理后台接口读取消息。 Pulsar Java client 通过Java client 可以创建生产者、消费者以及读取消息,当前API版本为2.5.0,包括两大块内容 包 描述 Maven Artifact org.apache.pulsar.client.api 创建生...

0
0
发表于服务端专区
2020/05/21 11:31

Pulsar笔记(好)

Pulsar 是由 Yahoo 于 2016 年开源并捐赠给 Apache 基金会的一款消息中间件,其主要特点是多租户且易于扩展,本文根据自己对 Pulsar 相关文档的理解并请教相关 PMC 后写成,囿于水平有限,错误难免,欢迎留言指正。 1 Pulsar vs Kafka 很多人查看 Pulsar 之前可能对 Kafka 很熟悉,参照上图可见二者内部结构的区别,下面详述二者的异同以明了 Pulsar 的特点。 1.1 名词对应表 根据个人对参考文档1的理解,整理如下Pulsar 和 Ka...

0
0
2020/12/24 19:00

共塑 Pulsar 未来,抽取 Pulsar 周边

关于 Apache Pulsar Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存储分离架构设计,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性。 GitHub 地址:http://github.com/apache/pulsar/ 一年一度的 Pulsar 调查活动来啦!Pulsar 2020 用户调查活动已启动,写下你的需求与建议,您...

0
0
2020/12/24 19:30

共塑 Pulsar 未来,抽取 Pulsar 周边

关于 Apache Pulsar Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存储分离架构设计,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性。 GitHub 地址:http://github.com/apache/pulsar/ 一年一度的 Pulsar 调查活动来啦!Pulsar 2020 用户调查活动已启动,写下你的需求与建议,您...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
0 评论
9 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部