阿里云文档 2024-12-02

Java客户端和Sarama Go客户端的兼容性说明

本文介绍了Java客户端和Sarama Go在数据层面和管控层面的兼容性详情。

文章 2024-02-22 来自:开发者社区

玩转Kafka—Spring&Go整合Kafka

玩转Kafka—Spring整合Kafka 1 新建Spring Boot项目,增加依赖 <dependencies> <dependency> <groupId>org.springframework.boot<...

玩转Kafka—Spring&Go整合Kafka
阿里云文档 2024-01-25

使用Go SDK接入Kafka并收发消息_云消息队列 Kafka 版(Kafka)

本文介绍如何使用Go SDK通过接入点接入云消息队列 Kafka 版并收发消息。

阿里云文档 2023-12-07

是否可以使用SaramaGo客户端收发消息

问题现象所有Sarama Go版本客户端存在以下已知问题:当Topic新增分区时,Sarama Go客户端无法感知并消费新增分区,需要客户端重启后,才能消费到新增分区。当Sarama Go客户端同时订阅两个以上的Topic时,有可能会导致部分分区无法正常消费消息。当Sarama Go客户端的消费位点...

问答 2023-10-30 来自:开发者社区

在阿里函数计算中,Kafka 触发器,调用方式是同步调用,Go 语言,在入口函数直接返回错误怎么搞?

在阿里函数计算中,Kafka 触发器,调用方式是同步调用,Go 语言,在入口函数直接返回错误:Kafka 触发器配置了退避重试,每个事件会处理 4 次,1 次 + 3 次重试。 在【触发器高级功能-重试策略】这里:说 429 错误 和 5xx 错误会触发重试。我在入口函数返回错误,是 5xx 错误?如果不是,为什么触发了重试?【因函数实现问题引发的函数执行出错】这里【执行出错】在使用 Go 语言....

文章 2023-02-05 来自:开发者社区

Docker部署kafka|Go操作实践

前言写作本文的背景是由于字节的暑期青训营中,某个项目要求编写一个简易的流处理引擎(flink),开发语言不限,推荐Java,本着好奇心的驱使,我打算使用Go语言进行部分尝试。既然是流处理引擎,那么首先需要有流式的数据源,一般而言,flink会配合从kafka中获取数据流,先不考虑后续编写引擎的部分,本文将着重于kafka的部署,并且后半段将给出使用Go语言编写kafka的生产者和消费者。如果你只....

Docker部署kafka|Go操作实践
文章 2023-01-08 来自:开发者社区

玩转Kafka—Spring&Go整合Kafka

玩转Kafka—Spring整合Kafka1 新建Spring Boot项目,增加依赖<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-we...

玩转Kafka—Spring&Go整合Kafka
问答 2021-10-18 来自:开发者社区

消息队列 kafka 使用go SDK 的confluent客户端

消息队列 kafka 使用go SDK 的confluent客户端, 只能在各自平台编译(darwin, windows, linux), 跨平台编译则失败

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

开发与运维

集结各类场景实战经验,助你开发运维畅行无忧

+关注