1. 云栖社区>
  2. 全部标签>
  3. #Consumer#
Consumer

#Consumer#

已有0人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

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

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

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

优酷外挂字幕技术实践

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

架构 模块 同步 Driver Consumer 字幕

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

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 注册中心的设计方案与实现

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

云栖社区 集群 容器 Consumer service

Apache RocketMQ 的 Service Mesh 开源之旅

自 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 开源之旅

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 开源之旅

自 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的区别

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

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

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

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

函数 string Consumer void test list Other

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

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

消息系统 java spring 配置 SSL Consumer Security

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

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

java 函数 code 表达式 Consumer void

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

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

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

实战:RocketMQ削峰,这一篇就够了

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

数据库 配置 测试 Consumer

玩转redis-简单消息队列

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

redis 消息队列 string Consumer type handler list

SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer

首先本地将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

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

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

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

CompletableFuture异步编排

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

线程 static Consumer void Other

55
GO