与Consumer相关精彩内容-云栖社区-阿里云

.net core kafka 入门实例一篇看懂

作者: 优惠码优惠 63人浏览

.net core kafka 入门实例一篇看懂 kafka 相信都有听说过，不管有没有用过，在江湖上可以说是大名鼎鼎，就像天龙八部里的乔峰。国际惯例，先介绍生平事迹简介Kafka 是由 Apache软件基金会开发的一个开源流处理平台，由 Scala 和 Java 编写。

消息系统配置集群 string Core Consumer class void

优酷外挂字幕技术实践

作者: 千言万语乐此不疲 275人浏览

优酷外挂字幕的目标是实现对全平台和全机型的覆盖，同时能支持 ass 之外的多种字幕格式、支持字幕互动等多种创新玩法。本文将分享我们对外挂字幕的探索与实践。

架构模块同步 Driver Consumer 字幕

spark-streaming-kafka-0-8 官网讲解

作者: 五维空间s 89人浏览

spark-streaming-kafka-0-8Note: Kafka 0.8 support is deprecated as of Spark 2.3.0.0.8在spark2.3中被标为过时的，但是没关系，还能用描述两种接收数据的方式receive 和Direct（spark1.3以后才有的）有receive的receive接收数据，在ui上有个jobid=0，使用kafka high-level consumer api，接收kafka数据先到executer内存里面，然后再启动streaming作业处理数据，但是在默认的配置下面可能会造成数据的丢失。

API Consumer zookeeper

dubbo-go K8s 注册中心的设计方案与实现

作者: 中间件小哥 373人浏览

Dubbo-go k8s注册中心设计方案与实现随着云原生的推广，越来越多的公司或组织将服务容器化，并将容器化后的服务部署在k8s集群中。今天这篇文章将会介绍dubbo-go将k8s作为服务注册中心的方案设计，以及具体实现。

云栖社区集群容器 Consumer service

Apache RocketMQ 的 Service Mesh 开源之旅

作者: 你say 110人浏览

自 19 年底开始，支持 Apache RocketMQ 的 Network Filter 历时 4 个月的 Code Review（[Pull Request](https://github.com/envoyproxy/envoy/pull/9503)），于本月正式合入 CNCF Envoy 官方社区（[RocketMQ Proxy Filter 官方文档](https://www.

消息系统 Apache sdk code 微服务 request 负载均衡 Consumer service kafka RocketMQ 云原生 servicemesh

Apache RocketMQ 的 Service Mesh 开源之旅

作者: 幸运券发放 149人浏览

Apache RocketMQ 的 Service Mesh 开源之旅作者 | 凌楚阿里巴巴开发工程师导读：自 19 年底开始，支持 Apache RocketMQ 的 Network Filter 历时 4 个月的 Code Review（Pull Request），于本月正式合入 CNCF Envoy 官方社区（RocketMQ Proxy Filter 官方文档），这使得 RocketMQ 成为继 Dubbo 之后，国内第二个成功进入 Service Mesh 官方社区的中间件产品。

Apache sdk code 微服务中间件 request 负载均衡 Consumer service

Apache RocketMQ 的 Service Mesh 开源之旅

作者: 阿里巴巴云原生小助手 167人浏览

自 19 年底开始，支持 Apache RocketMQ 的 Network Filter 历时 4 个月的 Code Review（Pull Request），于本月正式合入 CNCF Envoy 官方社区（RocketMQ Proxy Filter 官方文档），这使得 RocketMQ 成为继 Dubbo 之后，国内第二个成功进入 Service Mesh 官方社区的中间件产品。

Apache sdk 微服务中间件 request 负载均衡 Consumer service

好程序员大数据培训分享Redis与Kafka的区别

作者: 好程序员 126人浏览

　　好程序员大数据培训分享Redis与Kafka的区别，Kafka与Redis PUB/SUB之间较大的区别在于Kafka是一个完整的系统，而Redis PUB/SUB只是一个套件(utility)——没有冒犯Redis的意思，毕竟它的主要功能并不是PUB/SUB。

分布式大数据 redis 实时系统消息队列程序员负载均衡 Consumer 培训

【Java8新特性】还没搞懂函数式接口？赶快过来看看吧！

作者: 优惠码优惠 110人浏览

【Java8新特性】还没搞懂函数式接口？赶快过来看看吧！写在前面Java8中内置了一些在开发中常用的函数式接口，极大的提高了我们的开发效率。那么，问题来了，你知道都有哪些函数式接口吗？函数式接口总览这里，我使用表格的形式来简单说明下Java8中提供的函数式接口。

函数 string Consumer void test list Other

Spring Boot + Spring Kafka配置公网接入阿里云Kafka

作者: 那真的太谢谢你了 179人浏览

Spring Boot + Spring Kafka配置公网接入阿里云Kafka

消息系统 java spring 配置 SSL Consumer Security

Java8的函数式接口你真的了解吗？

作者: 云栖号资讯小哥 149人浏览

云栖号资讯：【点击查看更多行业资讯】在这里您可以找到不同行业的第一手的上云资讯，还在等什么，快来！函数式接口如果你的好奇心使你翻看Runnable接口源代码，你会发现该接口被一个@FunctionalInterface的注解修饰，这是 Java 8 中添加的新注解，用于表示「函数式接口」。

java 函数 code 表达式 Consumer void

【Java8新特性】Lambda表达式基础语法，都在这儿了！！

作者: 优惠码优惠 150人浏览

【Java8新特性】Lambda表达式基础语法，都在这儿了！！写在前面前面积极响应读者的需求，写了两篇Java新特性的文章。有小伙伴留言说：感觉Lambda表达式很强大啊！一行代码就能够搞定那么多功能！我想学习下Lambda表达式的语法，可以吗？我的回答是：没问题！这不，Lambda表达式来了！匿名类到Lambda表达式我们先来看看从匿名类如何转换到Lambda表达式呢？这里，我们可以使用两个示例来说明如何从匿名内部类转换为Lambda表达式。

函数 string 表达式 Consumer void test 数据类型

实战：RocketMQ削峰，这一篇就够了

作者: 云栖号资讯小哥 513人浏览

云栖号资讯：【点击查看更多行业资讯】在这里您可以找到不同行业的第一手的上云资讯，还在等什么，快来！前言MQ的主要特点为解耦、异步、削峰，该文章主要记录与分享个人在实际项目中的RocketMQ削峰用法，用于减少数据库压力的业务场景，其中RocketMQ的核心组件概念如下： Producer：生产.

数据库配置测试 Consumer

玩转redis-简单消息队列

作者: lpxxn 168人浏览

使用go语言基于redis写了一个简单的消息队列源码地址使用demo redis的 list 非常的灵活，可以从左边或者右边添加元素，当然也以从任意一头读取数据添加数据和获取数据的操作也是非常简单的LPUSH 从左边插入数据RPUSH 大右边插入数据LPOP 从左边取出一个数据RPOP 从右边取出一个数据 127.

redis 消息队列 string Consumer type handler list

SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer

作者: jerrywangsap 319人浏览

首先本地将kafka的docker容器镜像下载到本地并运行： docker search kafka docker pull spotify/kafka docker run --name kafka3 spotify/kafka docker ps命令，查看tcp端口号：新建一个gra...

云栖社区 docker 机器学习容器 Image Machine Consumer big data model ML learning

五分钟学后端技术：如何学习后端工程师必学的消息队列

作者: 程序员黄小斜 411人浏览

原创声明本文首发于微信公众号【程序员黄小斜】本文作者：黄小斜转载请务必在文章开头注明出处和作者。本文思维导图什么是消息队列 “RabbitMQ？”“Kafka？”“RocketMQ？”...在日常学习与开发过程中，我们常常听到消息队列这个关键词，可能你是熟练使用消息队列的老手，又或者你是不懂消息队列的新手，不论你了不了解消息队列，本文都将带你搞懂消息队列的一些基本理论。

分布式消息队列性能集群消息中间件 Consumer ActiveMQ Java，后端，消息队列

CompletableFuture异步编排

作者: 优惠券发放 182人浏览

CompletableFuture异步编排什么是CompletableFuture#CompletableFuture是JDK8提供的Future增强类。CompletableFuture异步任务执行线程池，默认是把异步任务都放在ForkJoinPool中执行。

线程 static Consumer void Other

#Consumer#